Uses of Class
fr.dyade.aaa.agent.AgentId

Packages that use AgentId

Package	Description
com.scalagent.joram.mom.dest.ftp
com.scalagent.joram.mom.dest.scheduler
fr.dyade.aaa.agent
fr.dyade.aaa.jndi2.distributed
fr.dyade.aaa.jndi2.server
org.objectweb.joram.client.jms.local
org.objectweb.joram.mom.dest	The org.objectweb.joram.mom.dest package holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM.
org.objectweb.joram.mom.notifications	The org.objectweb.joram.mom.notifications package holds the notifications used for interacting with the MOM destination agents.
org.objectweb.joram.mom.proxies	The org.objectweb.joram.mom.proxies package holds the classes implementing the MOM proxy, basically linking external client applications to destination agents.
org.objectweb.joram.mom.proxies.tcp	The org.objectweb.joram.mom.proxies.tcp package provides a proxy accessible through the TCP communication protocol.
org.objectweb.joram.mom.util
org.ow2.joram.jakarta.jms.local
org.ow2.joram.mom.amqp

Uses of AgentId in com.scalagent.joram.mom.dest.ftp

Fields in com.scalagent.joram.mom.dest.ftp declared as AgentId

Modifier and Type	Field	Description
private AgentId	FtpThread.destId
private AgentId	FtpQueue.dmq
private AgentId	FtpThread.dmqId

Methods in com.scalagent.joram.mom.dest.ftp with parameters of type AgentId

Modifier and Type	Method	Description
ClientMessages	FtpQueue.preProcess(AgentId from, ClientMessages not)
void	FtpQueue.react(AgentId from, Notification not)

Constructors in com.scalagent.joram.mom.dest.ftp with parameters of type AgentId

Constructor	Description
FtpThread(TransferItf transfer, FtpMessage ftpMsg, AgentId destId, AgentId dmqId, int clientContext, int requestId, String user, String pass, String path)

Uses of AgentId in com.scalagent.joram.mom.dest.scheduler

Fields in com.scalagent.joram.mom.dest.scheduler declared as AgentId

Modifier and Type	Field	Description
private AgentId	SchedulerQueueTask.schedulerQueue

Methods in com.scalagent.joram.mom.dest.scheduler with parameters of type AgentId

Modifier and Type	Method	Description
void	SchedulerQueue.react(AgentId from, Notification not)

Constructors in com.scalagent.joram.mom.dest.scheduler with parameters of type AgentId

Constructor	Description
SchedulerQueueTask(AgentId schedulerQueue)

Uses of AgentId in fr.dyade.aaa.agent

Fields in fr.dyade.aaa.agent declared as AgentId

Modifier and Type	Field	Description
AgentId	AgentCreateReply.agent
AgentId	DeleteAck.agent
AgentId	ExceptionNotification.agent	The target agent id.
AgentId	UnknownAgent.agent	The non-existent target agent id.
AgentId	UnknownNotification.agent	The target agent id.
private AgentId	MessageSoftRef.deadNotAgentId	The agent responsible of treating the notification when it expires.
(package private) AgentId	Notification.deadNotificationAgentId	The agentId identifying the agent to which the notification is sent when it is expired. Default value is null, which means the expired notification is lost.
(package private) AgentId	AgentCreateRequest.deploy	Id. of agent to deploy, used since id is not more serialized in agent state.
private AgentId	WakeUpTask.destId
(package private) static AgentId	AgentId.factoryId	AgentId for local factory agent.
private AgentId	ExpiredNot.from	The agent which sent the expired notification.
(package private) AgentId	Message.from	AgentId of sender.
(package private) AgentId	Agent.id	Global unique identifier of the agent.
private AgentId	Role.listener	The wrapped AgentId.
(package private) static AgentId	AgentId.localId	Used by channel to send messages without source agent (from proxy or engine).
static AgentId	AgentId.nullId	null AgentId.
AgentId	AgentCreateRequest.reply	Id. of agent to reply to
AgentId	AgentDeleteRequest.reply	the agent identified by 'reply' will receive a DeleteAck when destruction complete
AgentId	DeleteNot.reply	the agent identified by 'reply' will receive a DeleteAck when destruction complete
private AgentId	ExpiredNot.to	The destination agent of the expired notification.
(package private) AgentId	Message.to	AgentId of destination agent.
private AgentId	UnknownAgentException.unknownAgentId

Fields in fr.dyade.aaa.agent with type parameters of type AgentId

Modifier and Type	Field	Description
(package private) Hashtable<AgentId,Agent>	Engine.agents	This table is used to maintain a list of agents already in memory using the AgentId as primary key.
(package private) Vector<AgentId>	Engine.fixedAgentIdList	Vector containing id's of all fixed agents.
private Vector<AgentId>	RoleMultiple.list

Methods in fr.dyade.aaa.agent that return AgentId

Modifier and Type	Method	Description
static AgentId	AgentId.factoryId(short sid)	Returns the AgentId for a remote factory agent.
static AgentId	AgentId.fromString(String str)	Parses the string argument as an AgentId.
AgentId	MessageSoftRef.getDeadNotAgentId()	Returns the agent responsible of treating the notification when it expires.
AgentId	Notification.getDeadNotificationAgentId()
AgentId	AgentCreateRequest.getDeploy()
AgentId	Message.getFrom()
AgentId	ExpiredNot.getFromAgentId()
AgentId	Agent.getId()	Returns the global unique identifier of the agent.
AgentId	Role.getListener()	Returns the wrapped AgentId.
(package private) AgentId[]	Engine.getLoadedAgentIdlist()	Method used for debug and monitoring.
AgentId	AgentEngineContext.getLocalAgentId()	Returns the local agent id.
AgentId	AgentEngineContextImpl.getLocalAgentId()	Returns the local agent id.
AgentId	Message.getTo()
AgentId	ExpiredNot.getToAgentId()
AgentId	UnknownAgentException.getUnknownAgentId()	Returns the unknown agent identifier.
static AgentId	AgentId.localId(short sid)

Methods in fr.dyade.aaa.agent that return types with arguments of type AgentId

Modifier and Type	Method	Description
Enumeration<AgentId>	RoleMultiple.getListeners()	Gets the listeners list as an Enumeration of AgentId objects.

Methods in fr.dyade.aaa.agent with parameters of type AgentId

Modifier and Type	Method	Description
(package private) void	Engine.addFixedAgentId(AgentId id)	Adds an AgentId in the fixedAgentIdList Vector.
void	RoleMultiple.addListener(AgentId target)	Adds an agent in the listeners list.
(package private) static Message	Message.alloc(AgentId from, AgentId to, Notification not)	Allocates a message from the pool.
boolean	RoleMultiple.contains(AgentId id)	Tests if the specified agent id belongs to role multiple.
void	AgentEngine.createAgent(AgentId id, Agent agent)	Creates and initializes an agent.
void	Engine.createAgent(AgentId id, Agent agent)	Creates and initializes an agent.
Message	AgentEngineContext.createMessage(AgentId from, AgentId to, Notification not)	Creates a message.
Message	AgentEngineContextImpl.createMessage(AgentId from, AgentId to, Notification not)	Creates a message.
void	Agent.delete(AgentId agent)	Permits this agent to destroy itself.
void	Agent.delete(AgentId agent, Object extraInformation)	Permits this agent to destroy itself.
void	AgentEngine.deleteAgent(AgentId agent)	Deletes an agent.
void	Engine.deleteAgent(AgentId id)	Deletes an agent.
void	Agent.deploy(AgentId reply)	Deploys a new agent.
void	AgentEngineContext.directSendTo(AgentId to, Notification not)	Sends a notification to the specified destination with a local id.
void	AgentEngineContextImpl.directSendTo(AgentId to, Notification not)	Sends a notification to the specified destination with a local id.
(package private) void	Channel.directSendTo(AgentId from, AgentId to, Notification not)	Sends an immediately validated notification to an agent.
protected void	Agent.doAdminSyncNotification(AgentId from, AdminSyncNotification not)	Default handling of AdminSyncNotification.
String	AgentEngine.dumpAgent(AgentId id)	Returns a string representation of the specified agent.
String	Engine.dumpAgent(AgentId id)	Returns a string representation of the specified agent.
void	AgentEngineContext.initializeAgent(AgentId id, Agent agent)	Initializes an agent after creation.
void	AgentEngineContextImpl.initializeAgent(AgentId id, Agent agent)	Initializes an agent after creation.
private void	Agent.initState(String name, boolean fixed, AgentId id)
Object[]	SyncNotification.Context.invoke(AgentId to, long timeout)
Object[]	SyncNotification.invoke(AgentId to)
Object[]	SyncNotification.invoke(AgentId to, long timeout)
void	SyncNotification.invokeNoWait(AgentId to)
(package private) static Agent	Agent.load(AgentId id)	Restores the object state from the persistent storage.
static Agent	Agent.load(Transaction transaction, AgentId id)
(package private) Agent	Engine.load(AgentId id)	The load method return the Agent object designed by the AgentId parameter.
Agent	AgentEngineContext.loadAgent(AgentId id)	Loads the specified agent.
Agent	AgentEngineContextImpl.loadAgent(AgentId id)	Loads the specified agent.
void	AgentEngine.push(AgentId from, AgentId to, Notification not)	Puts a notification in the output queue.
void	AgentEngine.push(AgentId to, Notification not)	Puts a notification in the output queue.
void	Engine.push(AgentId from, AgentId to, Notification not)	Push a new message in temporary queue until the end of current reaction.
void	Engine.push(AgentId to, Notification not)	Push a new message in temporary queue until the end of current reaction.
void	Agent.react(AgentId from, Notification not)	Defines the reaction of the agent when receiving a notification.
void	AgentFactory.react(AgentId from, Notification not)	Reacts to notifications ... .
(package private) Agent	Engine.reload(AgentId id)	The reload method return the Agent object loaded from the storage.
(package private) void	Engine.removeFixedAgentId(AgentId id)	Removes an AgentId in the fixedAgentIdList Vector.
void	RoleMultiple.removeListener(AgentId target)	Removes an agent from the listeners list.
protected void	Agent.sendTo(AgentId to, Notification not)	This method sends a notification to the agent which id is given in parameter.
static void	Channel.sendTo(AgentId to, Notification not)	Sends a notification to an agent.
private void	Message.set(AgentId from, AgentId to, Notification not)
void	Notification.setDeadNotificationAgentId(AgentId deadNotificationAgentId)	Sets the forwardExpiredNotAgentId value which enable sending expired notifications to a specific agent
void	Role.setListener(AgentId listener)	Sets the wrapped AgentId.

Constructors in fr.dyade.aaa.agent with parameters of type AgentId

Constructor	Description
Agent(String name, boolean fixed, AgentId id)	Constructor used to build "system" agents like AgentFactory.
AgentCreateReply(AgentId agent)
AgentCreateRequest(Agent agent, AgentId reply)
AgentDeleteRequest(AgentId reply)
AgentDeleteRequest(AgentId reply, Object extraInformation)
AgentFactory(AgentId factoryId)	Allocates a new AgentFactory agent.
DeleteAck(AgentId agent)
DeleteAck(AgentId agent, int status)
DeleteAck(AgentId agent, Object extraInformation)
DeleteAck(AgentId agent, Throwable exc)
DeleteNot(AgentId reply)
ExceptionNotification(AgentId agent, Notification not, Exception exc)	Allocates a new ExceptionNotification notification.
ExpiredNot(Notification expiredNot, AgentId from, AgentId to)	Builds a notification carrying an expired notification.
Role(String name, AgentId listener)	Creates a new role with the specified name and AgentId.
UnknownAgent(AgentId agent, Notification not)	Allocates a new UnknownAgent notification.
UnknownAgentException(String s, AgentId unknownAgentId)	Constructs a new UnknownAgentException with the specified detail message and agent identifier.
UnknownNotification(AgentId agent, Notification not)	Allocates a new UnknownNotification notification.
WakeUpTask(AgentId id, Class<?> wakeUpNotClass, long period)	Creates a new WakeUpTask and schedules it.

Uses of AgentId in fr.dyade.aaa.jndi2.distributed

Fields in fr.dyade.aaa.jndi2.distributed declared as AgentId

Modifier and Type	Field	Description
private AgentId[]	InitJndiServerNot.jndiServerIds
private AgentId	ReplicationManager.rootOwnerId	Identifier of the server that owns the root naming context.

Methods in fr.dyade.aaa.jndi2.distributed that return AgentId

Modifier and Type	Method	Description
static AgentId	DistributedJndiServer.getDefault()	Returns the default JndiServer id on the local agent server.
static AgentId	DistributedJndiServer.getDefault(short serverId)	Returns the default JndiServer id on the given agent server.
AgentId[]	InitJndiServerNot.getJndiServerIds()
protected AgentId	ReplicationManager.getRootOwnerId()	Overrides the JndiServer behavior.

Methods in fr.dyade.aaa.jndi2.distributed with parameters of type AgentId

Modifier and Type	Method	Description
boolean	ReplicationEntryPoint.accept(AgentId from, Notification not)
(package private) void	ReplicationManager.doReact(AgentId from, InitJndiServerNot not)
(package private) void	ReplicationManager.doReact(AgentId from, JndiUpdateNot not)	Reacts to an update notification from an other JNDI server.
(package private) void	ReplicationManager.doReact(AgentId from, SyncReplyNot not)
(package private) void	ReplicationManager.doReact(AgentId from, SyncRequestNot not)
(package private) void	ReplicationManager.doReact(AgentId from, JndiReplyNot not)
(package private) void	ReplicationManager.doReact(AgentId from, JndiScriptReplyNot not)
protected JndiReply	ReplicationManager.invokeOwner(AgentId owner, RequestContext reqCtx)	Overrides the JndiServer behavior.
private void	ReplicationManager.onReply(AgentId from, JndiReply reply)	Reacts to the reply of a JNDI server that has been called as it is the owner of a naming context.
private void	ReplicationManager.onUpdateEvent(AgentId from, BindEvent evt)
private void	ReplicationManager.onUpdateEvent(AgentId from, ChangeOwnerEvent evt)
private void	ReplicationManager.onUpdateEvent(AgentId from, CreateSubcontextEvent evt)
private void	ReplicationManager.onUpdateEvent(AgentId from, DestroySubcontextEvent evt)
private void	ReplicationManager.onUpdateEvent(AgentId from, RebindEvent evt)
private void	ReplicationManager.onUpdateEvent(AgentId from, UnbindEvent evt)
private void	ReplicationManager.synchronizeRequest(AgentId owner, RequestContext reqCtx)

Constructors in fr.dyade.aaa.jndi2.distributed with parameters of type AgentId

Constructor	Description
InitJndiServerNot(AgentId[] jndiServerIds, NamingContextInfo[] contexts, boolean isRequest)

Uses of AgentId in fr.dyade.aaa.jndi2.server

Fields in fr.dyade.aaa.jndi2.server declared as AgentId

Modifier and Type	Field	Description
private AgentId	AgentRequestContext.from
private AgentId	TcpServer.serverId

Methods in fr.dyade.aaa.jndi2.server that return AgentId

Modifier and Type	Method	Description
static AgentId	JndiServer.getDefault()	Returns the default JndiServer id on the local agent server.
static AgentId	JndiServer.getDefault(short serverId)	Returns the default JndiServer id on the given agent server.
AgentId	AgentRequestContext.getFrom()
AgentId	RequestManager.getId()
protected AgentId	RequestManager.getRootOwnerId()	Returns the root naming context owner identifier.
AgentId	TcpServer.getServerId()

Methods in fr.dyade.aaa.jndi2.server with parameters of type AgentId

Modifier and Type	Method	Description
boolean	AgentEntryPoint.accept(AgentId from, Notification not)
boolean	EntryPoint.accept(AgentId from, Notification not)
boolean	TcpEntryPoint.accept(AgentId from, Notification not)
private void	AgentEntryPoint.doReact(AgentId from, JndiScriptRequestNot not)	Reacts to a JNDI script request.
protected JndiReply	RequestManager.invokeOwner(AgentId owner, RequestContext reqCtx)	A centralized JNDI server returns a JNDI error explaining that this server is not the owner of the context on which the JNDI operation is called.
void	Container.react(AgentId from, Notification not)
(package private) void	Container.sendNotification(AgentId to, Notification not)
void	RequestManager.sendTo(AgentId to, Notification not)

Constructors in fr.dyade.aaa.jndi2.server with parameters of type AgentId

Constructor	Description
AgentRequestContext(JndiRequest request, AgentId from, boolean doReply)
TcpServer(ServerSocket listen, int poolSize, AgentId serverId)

Uses of AgentId in org.objectweb.joram.client.jms.local

Fields in org.objectweb.joram.client.jms.local declared as AgentId

Modifier and Type	Field	Description
private AgentId	LocalRequestChannel.proxyId

Uses of AgentId in org.objectweb.joram.mom.dest

Fields in org.objectweb.joram.mom.dest declared as AgentId

Modifier and Type	Field	Description
(package private) static AgentId	AdminTopic.adminId
private AgentId	Destination.adminId	Identifier of the destination's administrator.
private AgentId	QueueDelivery.consumerId
(package private) static AgentId	Queue.defaultDMQId	Static value holding the default DMQ identifier for a server.
protected AgentId	Destination.dmqId	Identifier of the dead message queue this destination must send its dead messages to, if any.
protected AgentId	Topic.fatherId	Identifier of this topic's father, if any.
private AgentId	AdminTopic.DestinationDesc.id
(package private) AgentId	ElasticTopic.TopicDesc.id
private AgentId	AliasQueue.remoteDestinationID	The queue to send the notification to
private AgentId	NotificationDistributionHandler.remoteDestinationID	the queue to send the notification to

Fields in org.objectweb.joram.mom.dest with type parameters of type AgentId

Modifier and Type	Field	Description
protected Hashtable<AgentId,Integer>	Destination.clients	Table of the destination readers and writers.
protected Map<AgentId,Float>	ClusterQueue.clusters	key = agentId of ClusterQueue value = rateOfFlow (Float)
private ArrayList<AgentId>	AliasInQueue.destinations
protected Set<AgentId>	Topic.friends	Set of cluster elements (including itself), if any.
private Map<String,AgentId>	AdminTopic.proxiesTable	Table holding the TCP users proxies identifiers.
private Map<String,AgentId>	AdminTopic.requestsTable	Table keeping the administrator's requests.
protected Map<AgentId,String>	Topic.selectors	Table of subscribers' selectors.
protected List<AgentId>	Topic.subscribers	Vector of subscribers' identifiers.
private Map<String,List<AgentId>>	ClusterQueue.visitTable	key = msgId value = List (alreadyVisit)

Methods in org.objectweb.joram.mom.dest that return AgentId

Modifier and Type	Method	Description
AgentId	QueueDelivery.getConsumerId()
static AgentId	AdminTopic.getDefault()	Gets the identifier of the default administration topic on the current server.
static AgentId	AdminTopic.getDefault(short serverId)	Gets the identifier of the default administration topic on a given server.
static AgentId	Queue.getDefaultDMQId()	Static method returning the default DMQ identifier.
AgentId	Destination.getDMQAgentId()
AgentId	AdminTopic.DestinationDesc.getId()
private AgentId	AdminTopic.getProxyId(Identity identity, String inaddr)	Method used by ConnectionManager proxies to check their clients identification.
static AgentId	AdminTopic.lookupUser(String name)	Retrieves an existing user

Methods in org.objectweb.joram.mom.dest with parameters of type AgentId

Modifier and Type	Method	Description
protected void	Queue.abortReceiveRequest(AgentId from, AbortReceiveRequest not)
private void	AcquisitionTopic.acquisitionNot(AgentId from, AcquisitionNot not)	This method process messages from the acquisition module.
private void	AdminTopic.broadcastRequest(AdminRequest request, int avoidServerId, AgentId replyTo, String msgId)	Sends the administration request to AdminTopic of all servers except the given one.
protected void	Queue.browseRequest(AgentId from, BrowseRequest not)	Method implementing the queue reaction to a BrowseRequest instance, requesting an enumeration of the messages on the queue.
private void	Queue.clearQueue(AgentId replyTo, String requestMsgId, String replyMsgId)
protected void	Destination.clientMessages(AgentId from, ClientMessages not)	Method implementing the reaction to a ClientMessages notification holding messages sent by a client.
private void	ClusterQueue.clusterRemove(AgentId queue)	Remove the specified queue from current cluster.
private void	Topic.clusterRemove(AgentId topic)	Remove the specified topic from current cluster.
private AdminTopic.DestinationDesc	AdminTopic.createDestination(String destName, AgentId adminId, Properties properties, byte type, String className, String requestClassName, StringBuffer strbuf)	Instantiating the destination class or retrieving the destination.
static AdminTopic.DestinationDesc	AdminTopic.createDestinationAndSave(String destName, AgentId adminId, Properties properties, byte type, String className, String requestClassName, StringBuffer strbuf)	Deprecated.
protected TopicForwardNot	Topic.createTopicForward(AgentId destId, ClientMessages messages, boolean fromCluster)
static void	AdminTopic.CreateUserAndSave(CreateUserRequest request, AgentId replyTo, String msgId)	Deprecated.
void	AdminTopic.deleteNot(AgentId from, DeleteNot not)	Overrides this Destination method.
protected void	Destination.deleteNot(AgentId from, DeleteNot not)	Method implementing the reaction to a DeleteNot notification requesting the deletion of the destination.
private void	Queue.deleteQueueMessage(DeleteQueueMessage request, AgentId replyTo, String requestMsgId, String replyMsgId)
protected void	Queue.denyRequest(AgentId from, DenyRequest not)	Method implementing the reaction to a DenyRequest instance, requesting messages to be denied.
private void	AdminTopic.distributeReply(AgentId to, String msgId, AdminReply reply)	Actually sends an AdminReply object to an identified destination.
protected void	Queue.doAdminSyncNotification(AgentId from, AdminSyncNotification not)	Handling of AdminSyncNotification.
protected abstract void	Destination.doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)
protected void	ElasticTopic.doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)
protected void	Queue.doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)	Method specifically processing a ClientMessages instance.
protected void	Topic.doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)	Method specifically processing a ClientMessages instance.
private void	Topic.doClientMessages(AgentId from, ClientMessages not, boolean fromCluster, boolean throwsExceptionOnFullDest)
private void	AdminTopic.doProcess(AgentId replyTo, String msgId)
private void	AdminTopic.doProcess(AddDomainRequest request, AgentId replyTo, String msgId, AgentId from)	Adds a new domain to the configuration.
private void	AdminTopic.doProcess(AddServerRequest request, AgentId replyTo, String msgId, AgentId from)	Adds a server to the configuration.
private void	AdminTopic.doProcess(AdminCommandRequest request, AgentId replyTo, String requestMsgId)	Process an admin command.
private void	AdminTopic.doProcess(CreateDestinationRequest request, AgentId replyTo, String msgId)	Processes a CreateDestinationRequest instance requesting the creation of a destination.
private void	AdminTopic.doProcess(CreateUserRequest request, AgentId replyTo, String msgId)	Processes a CreateUserRequest instance requesting the creation of a UserAgent for a given user.
private void	AdminTopic.doProcess(DeleteDestination request, AgentId replyTo, String msgId)	Processes a DeleteDestination instance requesting the deletion of a destination.
private void	AdminTopic.doProcess(DeleteUser request, AgentId replyTo, String msgId)	Processes a DeleteUser instance requesting the deletion of a user.
private void	AdminTopic.doProcess(DestinationAdminRequest request, AgentId replyTo, String msgId)	Processes a DestinationRequest request by forwarding it to its target destination, if local.
private void	AdminTopic.doProcess(GetConfigRequest request, AgentId replyTo, String msgId)	Gets the current configuration.
private void	AdminTopic.doProcess(GetDestinationsRequest request, AgentId replyTo, String msgId)	Processes a Monitor_GetDestinations request by sending registered destinations.
private void	AdminTopic.doProcess(GetDMQSettingsRequest request, AgentId replyTo, String msgId)	Processes a Monitor_GetDMQSettings request either by processing it and sending back the default DMQ settings, or by forwarding it to its target destination or proxy.
private void	AdminTopic.doProcess(GetDomainNames request, AgentId replyTo, String msgId)
private void	AdminTopic.doProcess(GetJMXAttsRequest request, AgentId replyTo, String msgId)	Processes a Monitor_GetJMXAtts request or forwards it to its target destination if needed.
private void	AdminTopic.doProcess(GetRightsRequest request, AgentId replyTo, String msgId)	Processes a GetRightsRequest request by forwarding it to its target destination, if local.
private void	AdminTopic.doProcess(GetServersIdsRequest request, AgentId replyTo, String msgId)	Processes a Monitor_GetServersIds request by sending the list of the platform servers' ids.
private void	AdminTopic.doProcess(GetStatsRequest request, AgentId replyTo, String msgId)	Processes a Monitor_GetStat request or forwards it to its target destination if needed.
private void	AdminTopic.doProcess(GetUsersRequest request, AgentId replyTo, String msgId)	Processes a Monitor_GetUsers request by sending the users table.
private void	AdminTopic.doProcess(RemoveDomainRequest request, AgentId replyTo, String msgId, AgentId from)	Removes a domain in the configuration.
private void	AdminTopic.doProcess(RemoveServerRequest request, AgentId replyTo, String msgId, AgentId from)	Removes a server in the configuration.
private void	AdminTopic.doProcess(SetDMQRequest request, AgentId replyTo, String msgId)	Processes a SetDMQ request requesting a given queue to be set as the DMQ of a given destination or user.
private void	AdminTopic.doProcess(SetThresholdRequest request, AgentId replyTo, String msgId)	Processes a SetThreshold request requesting a given threshold value to be set as the threshold of a given destination or user.
private void	AdminTopic.doProcess(StopServerRequest request, AgentId replyTo, String msgId)	Processes a StopServerRequest instance requesting to stop a given server.
private void	AdminTopic.doProcess(UpdateUser request, AgentId replyTo, String msgId)	Processes an UpdateUser instance requesting to modify the identification of a user.
private void	AdminTopic.doProcess(UserAdminRequest request, AgentId replyTo, String requestMsgId)	Handle administration request about user.
protected abstract void	Destination.doRightRequest(AgentId user, int right)	This method is needed for right revocation.
protected void	Queue.doRightRequest(AgentId user, int right)	Method specifically processing a SetRightRequest instance.
protected void	Topic.doRightRequest(AgentId user, int right)	Method specifically processing a SetRightRequest instance.
protected void	Destination.forward(AgentId to, Notification not)
protected void	Topic.forwardMessages(AgentId from, ClientMessages messages)	Actually forwards a list of messages to the father or the cluster fellows, if any.
protected void	Topic.forwardMessages(AgentId from, ClientMessages messages, boolean fromCluster)
private void	Queue.getQueueMessage(GetQueueMessage request, AgentId replyTo, String requestMsgId, String replyMsgId)
private void	Queue.getQueueMessageIds(AgentId replyTo, String requestMsgId, String replyMsgId)
protected void	Destination.getRights(AgentId from, GetRightsRequestNot not)	Method implementing the reaction to a GetRightsRequest notification requesting the rights about this destination.
void	AliasInQueue.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
void	ClusterQueue.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
protected void	Destination.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
void	ElasticTopic.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)	This method handles the scaling operations.
void	Queue.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
void	Topic.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
private void	ElasticTopic.handleClientSubscriptionNot(AgentId from, ClientSubscriptionNot not)	If root, redirects subscriptions to proper topic.
protected void	AdminTopic.handleDeniedMessage(String msgId, AgentId replyTo)	Method used to send a response when a message is denied because of a lack of rights.
protected void	Destination.handleDeniedMessage(String msgId, AgentId replyTo)	Method used to do specific actions when a message is denied because of a lack of rights.
protected void	AliasInQueue.handleExpiredNot(AgentId from, ExpiredNot not)
protected void	AliasQueue.handleExpiredNot(AgentId from, ExpiredNot not)
protected void	Queue.handleExpiredNot(AgentId from, ExpiredNot not)
protected void	AliasInQueue.handlePongNot(AgentId from, PongNot not)
protected boolean	Destination.isAdministrator(AgentId client)	Checks the administering permission of a given client agent.
static boolean	AdminTopic.isAdminTopicId(AgentId id)	Returns true if the given AgentId is the unique identifier of an AdminTopic agent.
protected boolean	Destination.isLocal(AgentId id)
protected boolean	Destination.isReader(AgentId client)	Checks the reading permission of a given client agent.
protected boolean	Destination.isWriter(AgentId client)	Checks the writing permission of a given client agent.
private void	ClusterQueue.lBCycleLife(AgentId from, LBCycleLife not)	If the messages are not consumed by an other cluster's queue in a period of time, try to consume in this queue.
private void	ClusterQueue.lBMessageGive(AgentId from, LBMessageGive not)	load balancing message give by an other cluster queue. process ClientMessages, no need to check if sender is writer.
private void	ClusterQueue.lBMessageHope(AgentId from, LBMessageHope not)	load balancing message hope by the "from" queue.
ClientMessages	AcquisitionQueue.preProcess(AgentId from, ClientMessages cm)	Incoming JMS messages are processed by the acquisition module and a null ClientMessages is always returned to the base implementation.
ClientMessages	AcquisitionTopic.preProcess(AgentId from, ClientMessages cm)	Incoming JMS messages are processed by the acquisition module and a null ClientMessages is always returned to the base implementation.
protected ClientMessages	AdminTopic.preProcess(AgentId from, ClientMessages msgs)	Overrides this Destination method;
ClientMessages	AliasInQueue.preProcess(AgentId from, ClientMessages cm)
ClientMessages	AliasQueue.preProcess(AgentId from, ClientMessages cm)
ClientMessages	ClusterQueue.preProcess(AgentId from, ClientMessages not)	overload preProcess(AgentId, ClientMessages) store all msgId in timeTable and visitTable.
protected ClientMessages	Destination.preProcess(AgentId from, ClientMessages msgs)	This method is needed to add processing before the standard handling.
ClientMessages	DistributionQueue.preProcess(AgentId from, ClientMessages cm)
ClientMessages	DistributionTopic.preProcess(AgentId from, ClientMessages cm)	Be careful, the message must be completely loaded (body).
protected void	Destination.processAdminCommand(AdminCommandRequest request, AgentId replyTo, String requestMsgId)	Proccess an admin command.
private void	AdminTopic.processAdminRequests(AgentId replyTo, String msgId, AdminRequest request, AgentId from)	Method getting the administration requests from messages, and distributing them to the appropriate reactions.
(package private) void	Queue.processDeliveryTime(AgentId from, QueueDeliveryTimeNot not)
protected void	Topic.processMessages(AgentId from, ClientMessages not)	Actually processes the distribution of the received messages to the valid subscriptions by sending a TopicMsgsReply notification to the valid subscribers.
protected void	AliasInQueue.processSetRight(AgentId user, int right)
protected void	AliasQueue.processSetRight(AgentId user, int right)
protected void	Destination.processSetRight(AgentId user, int right)	set user right.
protected void	DistributionQueue.processSetRight(AgentId user, int right)
void	AcquisitionQueue.react(AgentId from, Notification not)
void	AcquisitionTopic.react(AgentId from, Notification not)
void	AdminTopic.react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.
void	AliasInQueue.react(AgentId from, Notification not)
void	AliasQueue.react(AgentId from, Notification not)
void	ClusterQueue.react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.
void	Destination.react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.
void	ElasticTopic.react(AgentId from, Notification not)
void	Queue.react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.
void	Topic.react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.
void	ClusterQueue.receiveRequest(AgentId from, ReceiveRequest not)
protected void	Queue.receiveRequest(AgentId from, ReceiveRequest not)	Method implementing the reaction to a ReceiveRequest instance, requesting a message.
static void	AdminTopic.registerDest(AgentId id, String name, byte type)	Registers a newly created destination.
protected void	Destination.replyToTopic(AdminReply reply, AgentId replyTo, String requestMsgId, String replyMsgId)
protected void	AdminTopic.requestGroupNot(AgentId from, RequestGroupNot not)
protected void	Destination.requestGroupNot(AgentId from, RequestGroupNot not)
void	Destination.setAdminId(AgentId adminId)	Sets the administrator of the destination.
protected void	Destination.setRight(SetRight request, AgentId replyTo, String requestMsgId, String replyMsgId)	Method implementing the reaction to a SetRightRequest notification requesting rights to be set for a user.
static void	AdminTopic.setRightAndSave(SetRight request, AgentId replyTo, String msgId)	Deprecated.
private void	ClusterQueue.storeMsgIdInVisitTable(String msgId, AgentId destId)
protected void	Topic.subscribeRequest(AgentId from, SubscribeRequest not)	Method implementing the reaction to a SubscribeRequest instance.
protected void	AdminTopic.topicForwardNot(AgentId from, TopicForwardNot not)	Overrides this Topic method; the forwarded messages contain admin requests and will be processed.
protected void	Topic.topicForwardNot(AgentId from, TopicForwardNot not)	Method implementing the reaction to a TopicForwardNot instance, carrying messages forwarded by a cluster fellow or a hierarchical son.
protected void	Destination.unknownAgent(AgentId from, UnknownAgent not)	Method implementing the reaction to an UnknownAgent notification.
protected void	Topic.unsubscribeRequest(AgentId from)	Method implementing the reaction to an UnsubscribeRequest instance, requesting to remove a subscriber.

Constructors in org.objectweb.joram.mom.dest with parameters of type AgentId

Constructor	Description
DestinationDesc(AgentId id, String name, byte type)
QueueDelivery(AgentId consumerId, int contextId, Message message)

Uses of AgentId in org.objectweb.joram.mom.notifications

Fields in org.objectweb.joram.mom.notifications declared as AgentId

Modifier and Type	Field	Description
private AgentId	ClientMessages.proxyId
private AgentId	ClusterJoinNot.replyTo	The JMS destination to send the reply
private AgentId	FwdAdminRequestNot.replyTo	The JMS destination to send the reply
private AgentId	ReceiveRequest.requester	Identifier of the client requesting a message, set by the queue if storing the request.
private AgentId	TopicDeliveryTimeNot.topic

Fields in org.objectweb.joram.mom.notifications with type parameters of type AgentId

Modifier and Type	Field	Description
private Set<AgentId>	ClusterJoinAck.cluster
private Set<AgentId>	ClusterJoinNot.cluster
private Vector<AgentId>	GetRightsReplyNot.readers	Vector of readers' identifiers.
private Map<String,List<AgentId>>	LBCycleLife.visitTable
private Vector<AgentId>	GetRightsReplyNot.writers	Vector of writers' identifiers.

Methods in org.objectweb.joram.mom.notifications that return AgentId

Modifier and Type	Method	Description
AgentId	ClientMessages.getDMQId()	Returns the identifier of the producer's dead message queue, if any.
AgentId[]	GetProxyIdListNot.getIds()
AgentId	ClientMessages.getProxyId()
AgentId	GetProxyIdNot.getProxyId()
AgentId	ClusterJoinNot.getReplyTo()	Returns the JMS destination to send the reply.
AgentId	FwdAdminRequestNot.getReplyTo()	Returns the JMS destination to send the reply.
AgentId	ReceiveRequest.getRequester()

Methods in org.objectweb.joram.mom.notifications that return types with arguments of type AgentId

Modifier and Type	Method	Description
Set<AgentId>	ClusterJoinAck.getCluster()
Set<AgentId>	ClusterJoinNot.getCluster()
Vector<AgentId>	GetRightsReplyNot.getReaders()	Returns the vector of readers' identifiers.
Map<String,List<AgentId>>	LBCycleLife.getVisitTable()
Vector<AgentId>	GetRightsReplyNot.getWriters()	Returns the vector of writers' identifiers.

Methods in org.objectweb.joram.mom.notifications with parameters of type AgentId

Modifier and Type	Method	Description
void	GetProxyIdListNot.Return(AgentId[] proxyIds)
void	GetProxyIdNot.Return(AgentId proxyId)
void	ClientMessages.setDMQId(AgentId dmqId)	Sets the identifier of the producer's dead message queue.
void	TopicMsgsReply.setDMQId(AgentId dmqId)	Sets the identifier of the producer's dead message queue.
void	ClientMessages.setProxyId(AgentId proxyId)
void	ReceiveRequest.setRequester(AgentId requester)

Method parameters in org.objectweb.joram.mom.notifications with type arguments of type AgentId

Modifier and Type	Method	Description
void	LBCycleLife.putInVisitTable(String msgId, List<AgentId> visit)

Constructors in org.objectweb.joram.mom.notifications with parameters of type AgentId

Constructor	Description
ClusterJoinNot(Set<AgentId> cluster, AgentId replyTo, String requestMsgId, String replyMsgId)
FwdAdminRequestNot(AdminRequest request, AgentId replyTo, String requestMsgId)	Creates a new FwdAdminRequestNot to send to a remote AdminTopic.
FwdAdminRequestNot(AdminRequest request, AgentId replyTo, String requestMsgId, String replyMsgId)	Creates a new FwdAdminRequestNot to send to an administered target (user or destination).
TopicDeliveryTimeNot(Message msg, AgentId topic, String subName)

Constructor parameters in org.objectweb.joram.mom.notifications with type arguments of type AgentId

Constructor	Description
ClusterJoinAck(Set<AgentId> cluster)
ClusterJoinNot(Set<AgentId> cluster, AgentId replyTo, String requestMsgId, String replyMsgId)
GetRightsReplyNot(AdminRequestNot request, boolean isFreeReading, boolean isFreeWriting, Vector<AgentId> readers, Vector<AgentId> writers)	Constructs a GetRightsReply instance.

Uses of AgentId in org.objectweb.joram.mom.proxies

Fields in org.objectweb.joram.mom.proxies declared as AgentId

Modifier and Type	Field	Description
private AgentId	ClientSubscription.dmqId	Identifier of the subscriber's dead message queue, null for DMQ not set.
private AgentId	UserAgent.dmqId	Identifier of this proxy dead message queue, null for DMQ not set.
private AgentId	AdminNotification.proxyId	The proxy's AgentId identifier.
private AgentId	ClientContext.proxyId	The proxy's agent identifier
private AgentId	ClientSubscription.proxyId	The proxy's agent identifier.
private AgentId	MultiCnxSync.proxyId
private AgentId	ClientSubscription.topicId	The topic identifier.
(package private) AgentId	CCUID.ua
private AgentId	UserAgent.HeartBeatTask.userId

Fields in org.objectweb.joram.mom.proxies with type parameters of type AgentId

Modifier and Type	Field	Description
private Hashtable<AgentId,AgentId>	ClientContext.deliveringQueues	Identifiers of queues delivering messages.
private Hashtable<AgentId,AgentId>	ClientContext.deliveringQueues	Identifiers of queues delivering messages.
private static Hashtable<AgentId,MultiCnxSync>	ConnectionManager.multiCnxSyncTable
private Vector<AgentId>	ClientContext.tempDestinations	Vector of temporary destinations.
private Map<AgentId,TopicSubscription>	UserAgent.topicsTable	Table holding the TopicSubscription instances.

Methods in org.objectweb.joram.mom.proxies that return AgentId

Modifier and Type	Method	Description
AgentId	ProxyAgentItf.getId()	Returns the proxy's AgentId identifier.
AgentId	AdminNotification.getProxyId()	Returns the AgentId of the proxy.
AgentId	ClientContext.getProxyId()
AgentId	ClientSubscription.getTopicId()	Returns the identifier of the subscription topic.

Methods in org.objectweb.joram.mom.proxies that return types with arguments of type AgentId

Modifier and Type	Method	Description
(package private) Iterator<AgentId>	ClientContext.getDeliveringQueues()	Returns the identifiers of the delivering queues.
(package private) Map<AgentId,AgentId>	ClientContext.getDeliveringQueueTable()
(package private) Map<AgentId,AgentId>	ClientContext.getDeliveringQueueTable()
(package private) List<AgentId>	ClientContext.getTempDestinationList()
(package private) Iterator<AgentId>	ClientContext.getTempDestinations()

Methods in org.objectweb.joram.mom.proxies with parameters of type AgentId

Modifier and Type	Method	Description
(package private) void	ClientContext.addDeliveringQueue(AgentId queueId)	Adds, if not already, the identifier of a delivering queue.
(package private) void	ClientContext.addTemporaryDestination(AgentId destId)	Adds a temporary destination identifier.
private void	UserAgent.deleteTemporaryDestination(AgentId destId)
private void	UserAgent.doFwd(AgentId from, AbstractReplyNot rep)	Distributes the JMS replies to the appropriate reactions.
private void	UserAgent.doFwd(AgentId from, QueueMsgReply rep)	Actually forwards a QueueMsgReply coming from a destination as a ConsumerMessages destinated to the requesting client.
private void	UserAgent.doFwd(AgentId from, TopicMsgsReply rep)	Method implementing the proxy reaction to a TopicMsgsReply.
private void	UserAgent.doReact(AgentId from, ExceptionReply rep)	Actually forwards an ExceptionReply coming from a destination as a MomExceptionReply destinated to the requesting client.
private void	UserAgent.doReact(AgentId from, GetClientSubscriptions not)	Used to get number of local subscribers to 'from'.
private void	UserAgent.doReact(AgentId from, ReconnectSubscribersNot not)	Sends reconnection messages to one or more subscribers.
private void	UserAgent.doReact(AdminCommandRequest request, AgentId replyTo, String requestMsgId)
private void	UserAgent.doReact(ClearSubscription request, AgentId replyTo, String requestMsgId, String replyMsgId)
private void	UserAgent.doReact(DeleteSubscriptionMessage request, AgentId replyTo, String requestMsgId, String replyMsgId)
private void	UserAgent.doReact(GetSubscriptionMessageIds request, AgentId replyTo, String requestMsgId, String replyMsgId)
private void	UserAgent.doReact(GetSubscriptionMessage request, AgentId replyTo, String requestMsgId, String replyMsgId)
private void	UserAgent.doReact(GetSubscription request, AgentId replyTo, String requestMsgId, String replyMsgId)
private void	UserAgent.doReact(GetSubscriptions request, AgentId replyTo, String requestMsgId, String replyMsgId)
static MultiCnxSync	ConnectionManager.getMultiCnxSync(AgentId proxyId)
static String	ClientContext.getTransactionPrefix(AgentId proxyId)
static String	ClientSubscription.getTransactionPrefix(AgentId proxyId)
static boolean	UserAgent.isValidCC(AgentId ua, int ctxid)
void	UserAgent.react(AgentId from, Notification not)	Overrides the Agent class react method for providing the JMS client proxy with its specific behaviour.
(package private) void	ClientSubscription.reactivate(int contextId, int reqId, AgentId topicId, String selector, boolean noLocal)	Reactivates the subscription.
(package private) void	ClientContext.removeTemporaryDestination(AgentId destId)	Removes a temporary destination identifier.
private void	UserAgent.replyToTopic(AdminReply reply, AgentId replyTo, String requestMsgId, String replyMsgId)
void	ProxyAgentItf.sendNot(AgentId to, Notification not)	Sends a notification to a given agent.
void	UserAgent.sendNot(AgentId to, Notification not)	Sends a notification to the specified agent.
static void	ConnectionManager.sendToProxy(AgentId proxyId, int cnxKey, AbstractJmsRequest req, Object msg, ConnectionContext ctx)
(package private) void	ClientSubscription.setDMQId(AgentId dmqId)	Sets the subscription's dead message queue identifier.
private boolean	UserAgent.updateSubscriptionToTopic(AgentId topicId, int contextId, int requestId)	Updates the proxy's subscription to a topic.
private boolean	UserAgent.updateSubscriptionToTopic(AgentId topicId, int contextId, int requestId, boolean asyncSub)	Updates the proxy's subscription to a topic.

Constructors in org.objectweb.joram.mom.proxies with parameters of type AgentId

Constructor	Description
AdminNotification(AgentId proxyId, Identity identity)	Constructs an AdminNotification instance.
CCUID(AgentId ua, int ctxid)
ClientContext(AgentId proxyId, int id)	Constructs a ClientContext instance.
ClientSubscription(AgentId proxyId, int contextId, int reqId, boolean durable, AgentId topicId, String name, String selector, boolean noLocal, AgentId dmqId, int threshold, int nbMaxMsg, MessageTable messagesTable, String clientID)	Constructs a ClientSubscription instance.
HeartBeatTask(int timeout, Integer key, AgentId userId)
MultiCnxSync(AgentId pid)

Uses of AgentId in org.objectweb.joram.mom.proxies.tcp

Fields in org.objectweb.joram.mom.proxies.tcp declared as AgentId

Modifier and Type	Field	Description
private AgentId	TcpConnection.proxyId
private AgentId	TcpReader.proxyId

Methods in org.objectweb.joram.mom.proxies.tcp that return AgentId

Modifier and Type	Method	Description
AgentId	TcpConnection.getProxyId()

Methods in org.objectweb.joram.mom.proxies.tcp with parameters of type AgentId

Modifier and Type	Method	Description
(package private) TcpConnection	TcpProxyService.getConnection(AgentId proxyId, int key)

Constructors in org.objectweb.joram.mom.proxies.tcp with parameters of type AgentId

Constructor	Description
TcpConnection(IOControl ioctrl, ReliableConnectionContext ctx, AgentId proxyId, TcpProxyService proxyService, Identity identity)	Creates a new TCP connection.
TcpReader(IOControl ioctrl, AgentId proxyId, TcpConnection tcpConnection, boolean closeConnection, ConnectionContext ctx)	Creates a new reader.

Uses of AgentId in org.objectweb.joram.mom.util

Fields in org.objectweb.joram.mom.util declared as AgentId

Modifier and Type	Field	Description
private AgentId	DMQManager.destDmqId
private AgentId	QueueDeliveryTimeTask.destId
private AgentId	TopicDeliveryTimeTask.destId
private AgentId	DMQManager.senderId
private AgentId	TopicDeliveryTimeTask.topic

Methods in org.objectweb.joram.mom.util that return AgentId

Modifier and Type	Method	Description
static AgentId	JoramHelper.createDestination(String destName, AgentId adminId, String destClassName, byte type, Properties properties, boolean freerw)	Instantiating the destination class or retrieving the destination.
static AgentId	JoramHelper.createDestination(String destName, AgentId adminId, String destClassName, byte type, Properties properties, boolean freeReading, boolean freeWriting)	Instantiating the destination class or retrieving the destination.

Methods in org.objectweb.joram.mom.util with parameters of type AgentId

Modifier and Type	Method	Description
static AgentId	JoramHelper.createDestination(String destName, AgentId adminId, String destClassName, byte type, Properties properties, boolean freerw)	Instantiating the destination class or retrieving the destination.
static AgentId	JoramHelper.createDestination(String destName, AgentId adminId, String destClassName, byte type, Properties properties, boolean freeReading, boolean freeWriting)	Instantiating the destination class or retrieving the destination.
void	SynchronousAgent.react(AgentId from, Notification not)	Deprecated.

Constructors in org.objectweb.joram.mom.util with parameters of type AgentId

Constructor	Description
DMQManager(AgentId currentDestDmq, AgentId senderId)	Creates a DMQManager.
DMQManager(AgentId specificDmq, AgentId currentDestDmq, AgentId senderId)	Creates a DMQManager.
QueueDeliveryTimeTask(AgentId destId, Message msg, boolean throwsExceptionOnFullDest)
TopicDeliveryTimeTask(AgentId destId, AgentId topic, String subName, Message msg)

Uses of AgentId in org.ow2.joram.jakarta.jms.local

Fields in org.ow2.joram.jakarta.jms.local declared as AgentId

Modifier and Type	Field	Description
private AgentId	LocalRequestChannel.proxyId

Uses of AgentId in org.ow2.joram.mom.amqp

Methods in org.ow2.joram.mom.amqp that return AgentId

Modifier and Type	Method	Description
static AgentId	AMQPAgent.getAMQPId(short serverId)	get destination AgentId of AMQPAgent.

Methods in org.ow2.joram.mom.amqp with parameters of type AgentId

Modifier and Type	Method	Description
static void	StubAgentIn.processRequest(AgentId from, long keyLock, long proxyId, Object request)
static void	StubAgentIn.processResponse(AgentId from, long keyLock, Object response)
static void	AMQPAgent.putResponse(AgentId from, long lock, Object response)
void	AMQPAgent.react(AgentId from, Notification not)	Distributes the received notifications to the appropriate reactions.