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

Packages that use AgentId
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.ha   
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.dest.jmsbridge The org.objectweb.joram.mom.dest.jmsbridge package provides utility classes used by the MOM destinations and proxies. 
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.soap The org.objectweb.joram.mom.proxies.soap package provides a proxy accessible through the SOAP communication protocol. 
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   
 

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

Fields in com.scalagent.joram.mom.dest.ftp declared as AgentId
private  AgentId FtpThread.destId
           
private  AgentId FtpQueueImpl.dmq
           
private  AgentId FtpThread.dmqId
           
 

Methods in com.scalagent.joram.mom.dest.ftp with parameters of type AgentId
 DestinationImpl FtpQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the FtpQueueImpl.
 ClientMessages FtpQueueImpl.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
FtpQueueImpl(AgentId adminId, java.util.Properties prop)
          Constructs a FtpQueueImpl instance.
FtpThread(TransferItf transfer, FtpMessage ftpMsg, AgentId destId, AgentId dmqId, int clientContext, int requestId, java.lang.String user, java.lang.String pass, java.lang.String path)
           
 

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

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

Methods in com.scalagent.joram.mom.dest.scheduler with parameters of type AgentId
 DestinationImpl SchedulerQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the QueueImpl.
 void SchedulerQueue.react(AgentId from, Notification not)
           
 

Constructors in com.scalagent.joram.mom.dest.scheduler with parameters of type AgentId
SchedulerQueueImpl(AgentId adminId, java.util.Properties prop)
          Constructs a SchedulerQueueImpl instance.
SchedulerQueueTask(AgentId schedulerQueue)
           
 

Uses of AgentId in fr.dyade.aaa.agent
 

Fields in fr.dyade.aaa.agent declared as AgentId
 AgentId UnknownNotification.agent
          The target agent id.
 AgentId UnknownAgent.agent
          The non-existent target agent id.
 AgentId ExceptionNotification.agent
          The target agent id.
 AgentId DeleteAck.agent
           
 AgentId AgentCreateReply.agent
           
(package private)  AgentId Notification.deadNotificationAgentId
          The agentId identifying the agent to which the notification is sent when it is expired.
(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.
(package private)  AgentId Message.from
          AgentId of sender.
private  AgentId ExpiredNot.from
          The agent which sent the expired notification.
(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 DeleteNot.reply
          the agent identified by 'reply' will receive a DeleteAck when destruction complete
 AgentId AgentDeleteRequest.reply
          the agent identified by 'reply' will receive a DeleteAck when destruction complete
 AgentId AgentCreateRequest.reply
          Id. of agent to reply to
(package private)  AgentId Message.to
          AgentId of destination agent.
private  AgentId ExpiredNot.to
          The destination agent of the expired notification.
 

Methods in fr.dyade.aaa.agent that return AgentId
static AgentId AgentId.factoryId(short sid)
          Returns the AgentId for a remote factory agent.
static AgentId AgentId.fromString(java.lang.String str)
          Parses the string argument as an AgentId.
 AgentId Notification.getDeadNotificationAgentId()
           
 AgentId AgentCreateRequest.getDeploy()
           
 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 ExpiredNot.getToAgentId()
           
static AgentId AgentId.localId(short sid)
           
 

Methods in fr.dyade.aaa.agent with parameters of type AgentId
(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.
(package private)  void Engine.createAgent(AgentId id, Agent agent)
          Creates and initializes an agent.
 void Agent.delete(AgentId agent)
          Permits this agent to destroy itself.
 void Agent.delete(AgentId agent, java.lang.Object extraInformation)
          Permits this agent to destroy itself.
(package private)  void Engine.deleteAgent(AgentId from)
          Deletes an agent.
 void Agent.deploy(AgentId reply)
          Deploys a new agent.
(package private)  void Channel.directSendTo(AgentId from, AgentId to, Notification not)
          Sends an immediately validated notification to an agent.
 java.lang.String Engine.dumpAgent(AgentId id)
          Returns a string representation of the specified agent.
private  void Agent.initState(java.lang.String name, boolean fixed, AgentId id)
           
 java.lang.Object[] SyncNotification.invoke(AgentId to)
           
 java.lang.Object[] SyncNotification.Context.invoke(AgentId to)
           
(package private)  Agent Engine.load(AgentId id)
          The load method return the Agent object designed by the AgentId parameter.
(package private) static Agent Agent.load(AgentId id)
          Restores the object state from the persistent storage.
(package private)  void Engine.push(AgentId from, AgentId to, Notification not)
          Push a new message in temporary queue until the end of current reaction.
 void AgentFactory.react(AgentId from, Notification not)
          Reacts to notifications ... .
 void Agent.react(AgentId from, Notification not)
          Defines the reaction of the agent when receiving a notification.
(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.
static void Channel.sendTo(AgentId to, Notification not)
          Sends a notification to an agent.
protected  void Agent.sendTo(AgentId to, Notification not)
          This method sends a notification to the agent which id is given in parameter.
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
Agent(java.lang.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, java.lang.Object extraInformation)
           
AgentFactory(AgentId factoryId)
          Allocates a new AgentFactory agent.
DeleteAck(AgentId agent)
           
DeleteAck(AgentId agent, int status)
           
DeleteAck(AgentId agent, java.lang.Object extraInformation)
           
DeleteAck(AgentId agent, java.lang.Throwable exc)
           
DeleteNot(AgentId reply)
           
ExceptionNotification(AgentId agent, Notification not, java.lang.Exception exc)
          Allocates a new ExceptionNotification notification.
ExpiredNot(Notification expiredNot, AgentId from, AgentId to)
          Builds a notification carrying an expired notification.
Role(java.lang.String name, AgentId listener)
          Creates a new role with the specified name and AgentId.
UnknownAgent(AgentId agent, Notification not)
          Allocates a new UnknownAgent notification.
UnknownNotification(AgentId agent, Notification not)
          Allocates a new UnknownNotification notification.
WakeUpTask(AgentId id, java.lang.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
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
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
 boolean ReplicationEntryPoint.accept(AgentId from, Notification not)
           
(package private)  void ReplicationManager.doReact(AgentId from, InitJndiServerNot not)
           
(package private)  void ReplicationManager.doReact(AgentId from, JndiReplyNot not)
           
(package private)  void ReplicationManager.doReact(AgentId from, JndiScriptReplyNot 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)
           
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
InitJndiServerNot(AgentId[] jndiServerIds, NamingContextInfo[] contexts, boolean isRequest)
           
 

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

Fields in fr.dyade.aaa.jndi2.ha declared as AgentId
private  AgentId HATcpServer.serverId
           
 

Methods in fr.dyade.aaa.jndi2.ha that return AgentId
static AgentId HAJndiServer.getDefault()
          Returns the default JndiServer id on the local agent server.
static AgentId HADistributedJndiServer.getDefault()
          Returns the default JndiServer id on the local agent server.
static AgentId HAJndiServer.getDefault(short serverId)
          Returns the default JndiServer id on the given agent server.
static AgentId HADistributedJndiServer.getDefault(short serverId)
          Returns the default JndiServer id on the given agent server.
 AgentId HATcpServer.getServerId()
           
 

Methods in fr.dyade.aaa.jndi2.ha with parameters of type AgentId
 boolean HAEntryPoint.accept(AgentId from, Notification not)
           
 

Constructors in fr.dyade.aaa.jndi2.ha with parameters of type AgentId
HATcpServer(java.net.ServerSocket listen, int nbm, AgentId serverId)
           
 

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

Fields in fr.dyade.aaa.jndi2.server declared as AgentId
private  AgentId AgentRequestContext.from
           
private  AgentId TcpServer.serverId
           
 

Methods in fr.dyade.aaa.jndi2.server that return AgentId
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
 boolean TcpEntryPoint.accept(AgentId from, Notification not)
           
 boolean EntryPoint.accept(AgentId from, Notification not)
           
 boolean AgentEntryPoint.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
AgentRequestContext(JndiRequest request, AgentId from, boolean doReply)
           
TcpServer(java.net.ServerSocket listen, int poolSize, int timeout, AgentId serverId)
           
 

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

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

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

Fields in org.objectweb.joram.mom.dest declared as AgentId
private  AgentId DestinationImpl.adminId
          Identifier of the destination's administrator.
(package private) static AgentId AdminTopic.adminId
           
(package private) static AgentId QueueImpl.defaultDMQId
          Static value holding the default DMQ identifier for a server.
protected  AgentId DestinationImpl.dmqId
          Identifier of the dead message queue this destination must send its dead messages to, if any.
protected  AgentId TopicImpl.fatherId
          Identifier of this topic's father, if any.
private  AgentId AdminTopicImpl.DestinationDesc.id
           
private  AgentId ClusterTest.replyTo
          The JMS destination to send the reply
private  AgentId ClusterAck.replyTo
          The JMS destination to send the reply
(package private)  AgentId ClusterNot.topicId
          The identifier of the topic to add to the cluster.
 

Methods in org.objectweb.joram.mom.dest that return AgentId
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 QueueImpl.getDefaultDMQId()
          Static method returning the default DMQ identifier.
 AgentId DestinationImpl.getDMQAgentId()
           
 AgentId DestinationImpl.getId()
          Identifier of the agent hosting the destination.
 AgentId AdminTopicImpl.DestinationDesc.getId()
           
 AgentId AdminTopicImpl.getProxyId(Identity identity, java.lang.String inaddr)
          Method used by ConnectionManager proxies to check their clients identification.
 AgentId ClusterTest.getReplyTo()
          Returns the JMS destination to send the reply.
 AgentId ClusterAck.getReplyTo()
          Returns the JMS destination to send the reply.
 

Methods in org.objectweb.joram.mom.dest with parameters of type AgentId
 void QueueImpl.abortReceiveRequest(AgentId from, AbortReceiveRequest not)
           
private  void AdminTopicImpl.broadcastRequest(AdminRequest request, int avoidServerId, AgentId replyTo, java.lang.String msgId)
          Sends the administration request to AdminTopic of all servers except the given one.
 void QueueImpl.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 QueueImpl.clearQueue(AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
protected  void DestinationImpl.clientMessages(AgentId from, ClientMessages not)
          Method implementing the reaction to a ClientMessages notification holding messages sent by a client.
 void TopicImpl.clusterAck(AgentId from, ClusterAck ack)
          Method implementing the reaction to a ClusterAck notification sent by a topic requested to join the cluster.
 void AdminTopicImpl.clusterAck(AgentId from, ClusterAck ack)
          Overrides this TopicImpl method; a ClusterAck is not expected by an AdminTopic.
 void TopicImpl.clusterNot(AgentId from, ClusterNot not)
          Method implementing the reaction to a ClusterNot notification sent by a fellow topic for notifying this topic of a new cluster fellow insertion or suppression.
 void AdminTopicImpl.clusterNot(AgentId from, ClusterNot not)
          Overrides this TopicImpl method; if this AdminTopic is on server0, new cluster fellow is notified to other fellows and other fellows are notified to it.
 void TopicImpl.clusterTest(AgentId from, ClusterTest not)
          Method implementing the reaction to a ClusterTest notification sent by a fellow topic for testing if this topic might be part of a cluster.
 void AdminTopicImpl.clusterTest(AgentId from, ClusterTest request)
          Overrides this TopicImpl method; AdminTopics do not accept to join clusters other than their admin topics cluster.
 AdminTopicImpl.DestinationDesc AdminTopicImpl.createDestination(java.lang.String destName, AgentId adminId, java.util.Properties properties, byte type, java.lang.String className, java.lang.String requestClassName, java.lang.StringBuffer strbuf)
          Instantiating the destination class or retrieving the destination.
 DestinationImpl Topic.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the TopicImpl.
 DestinationImpl Queue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the QueueImpl.
 DestinationImpl DistributionTopic.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the DistributionTopicImpl.
 DestinationImpl DistributionQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the DistributionQueueImpl.
abstract  DestinationImpl Destination.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the specific implementation.
 DestinationImpl DeadMQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Deprecated. Creates the dead message queue.
 DestinationImpl ClusterQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the QueueImpl.
 DestinationImpl AdminTopic.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the TopicImpl.
 DestinationImpl AcquisitionTopic.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the AcquisitionTopicImpl.
 DestinationImpl AcquisitionQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the AcquisitionQueueImpl.
 void DestinationImpl.deleteNot(AgentId from, DeleteNot not)
          Method implementing the reaction to a DeleteNot notification requesting the deletion of the destination.
 void AdminTopicImpl.deleteNot(AgentId from, DeleteNot not)
          Overrides this DestinationImpl method.
private  void QueueImpl.deleteQueueMessage(DeleteQueueMessage request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
 void QueueImpl.denyRequest(AgentId from, DenyRequest not)
          Method implementing the reaction to a DenyRequest instance, requesting messages to be denied.
private  void AdminTopicImpl.distributeReply(AgentId to, java.lang.String msgId, AdminReply reply)
          Actually sends an AdminReply object to an identified destination.
protected  void TopicImpl.doClientMessages(AgentId from, ClientMessages not)
          Method specifically processing a ClientMessages instance.
protected  void QueueImpl.doClientMessages(AgentId from, ClientMessages not)
          Method specifically processing a ClientMessages instance.
protected abstract  void DestinationImpl.doClientMessages(AgentId from, ClientMessages not)
           
private  void AdminTopicImpl.doProcess(AddDomainRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
          Adds a new domain to the configuration.
private  void AdminTopicImpl.doProcess(AddServerRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
          Adds a server to the configuration.
private  void AdminTopicImpl.doProcess(AgentId replyTo, java.lang.String msgId)
           
private  void AdminTopicImpl.doProcess(CreateDestinationRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a CreateDestinationRequest instance requesting the creation of a destination.
private  void AdminTopicImpl.doProcess(CreateUserRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a CreateUserRequest instance requesting the creation of a UserAgent for a given user.
private  void AdminTopicImpl.doProcess(DeleteDestination request, AgentId replyTo, java.lang.String msgId)
          Processes a DeleteDestination instance requesting the deletion of a destination.
private  void AdminTopicImpl.doProcess(DeleteUser request, AgentId replyTo, java.lang.String msgId)
          Processes a DeleteUser instance requesting the deletion of a user.
private  void AdminTopicImpl.doProcess(GetClusterRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetCluster request by forwarding it to its target topic, if local.
private  void AdminTopicImpl.doProcess(GetConfigRequest request, AgentId replyTo, java.lang.String msgId)
          Gets the current configuration.
private  void AdminTopicImpl.doProcess(GetDestinationsRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetDestinations request by sending registered destinations.
private  void AdminTopicImpl.doProcess(GetDMQSettingsRequest request, AgentId replyTo, java.lang.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 AdminTopicImpl.doProcess(GetDomainNames request, AgentId replyTo, java.lang.String msgId)
           
private  void AdminTopicImpl.doProcess(GetFatherRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetFather request by forwarding it to its target topic, if local.
private  void AdminTopicImpl.doProcess(GetNbMaxMsgRequest request, AgentId replyTo, java.lang.String msgId)
          Processes an Monitor_GetNbMaxMsg request requesting to get the maximum number of messages.
private  void AdminTopicImpl.doProcess(GetPendingMessages request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetPendingMessages request by forwarding it to its target queue, if local.
private  void AdminTopicImpl.doProcess(GetPendingRequests request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetPendingRequests request by forwarding it to its target queue, if local.
private  void AdminTopicImpl.doProcess(GetRightsRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a GetRightsRequest request by forwarding it to its target destination, if local.
private  void AdminTopicImpl.doProcess(GetServersIdsRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetServersIds request by sending the list of the platform servers' ids.
private  void AdminTopicImpl.doProcess(GetStatsRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetStat request by forwarding it to its target destination, if local.
private  void AdminTopicImpl.doProcess(GetSubscriberIds request, AgentId replyTo, java.lang.String requestMsgId)
           
private  void AdminTopicImpl.doProcess(GetSubscriptionsRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetSubscriptions request by forwarding it to its target queue, if local.
private  void AdminTopicImpl.doProcess(GetUsersRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a Monitor_GetUsers request by sending the users table.
private  void AdminTopicImpl.doProcess(QueueAdminRequest request, AgentId replyTo, java.lang.String requestMsgId)
           
private  void AdminTopicImpl.doProcess(RemoveDomainRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
          Removes a domain in the configuration.
private  void AdminTopicImpl.doProcess(RemoveServerRequest request, AgentId replyTo, java.lang.String msgId, AgentId from)
          Removes a server in the configuration.
private  void AdminTopicImpl.doProcess(SetCluster request, AgentId replyTo, java.lang.String msgId)
          Processes a SetCluster instance requesting to link two topics in a cluster relationship.
private  void AdminTopicImpl.doProcess(SetDMQRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a SetDMQ request requesting a given queue to be set as the DMQ of a given destination or user.
private  void AdminTopicImpl.doProcess(SetFather request, AgentId replyTo, java.lang.String msgId)
          Processes a SetFather instance requesting to link two topics in a hierarchical relationship.
private  void AdminTopicImpl.doProcess(SetNbMaxMsgRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a SetNbMaxMsg request requesting a given nbMaxMsg value to be set in queue or subscription.
 void AdminTopicImpl.doProcess(SetRight request, AgentId replyTo, java.lang.String msgId)
          Processes a SetRight instance requesting to grant a user a given right on a given destination.
private  void AdminTopicImpl.doProcess(SetThresholdRequest request, AgentId replyTo, java.lang.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 AdminTopicImpl.doProcess(SpecialAdmin request, AgentId replyTo, java.lang.String msgId)
           
private  void AdminTopicImpl.doProcess(StopServerRequest request, AgentId replyTo, java.lang.String msgId)
          Processes a StopServerRequest instance requesting to stop a given server.
private  void AdminTopicImpl.doProcess(UpdateUser request, AgentId replyTo, java.lang.String msgId)
          Processes an UpdateUser instance requesting to modify the identification of a user.
private  void AdminTopicImpl.doProcess(UserAdminRequest request, AgentId replyTo, java.lang.String requestMsgId)
          Handle administration request about user.
protected  void TopicImpl.doRightRequest(AgentId user, int right)
          Method specifically processing a SetRightRequest instance.
protected  void QueueImpl.doRightRequest(AgentId user, int right)
          Method specifically processing a SetRightRequest instance.
protected abstract  void DestinationImpl.doRightRequest(AgentId user, int right)
          This method is needed for right revocation.
 void DestinationImpl.forward(AgentId to, Notification not)
           
 java.lang.String AdminTopicImpl.getName(AgentId proxyId)
          Method used by proxies for retrieving their name.
 java.lang.Object AdminTopicImpl.getPassword(AgentId proxyId)
          Method used by proxies for retrieving their password.
private  void QueueImpl.getQueueMessage(GetQueueMessage request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
private  void QueueImpl.getQueueMessageIds(AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
 void DestinationImpl.getRights(AgentId from, GetRightsRequestNot not)
          Method implementing the reaction to a GetRightsRequest notification requesting the rights about this destination.
 void TopicImpl.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
           
 void QueueImpl.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
           
 void DestinationImpl.handleAdminRequestNot(AgentId from, FwdAdminRequestNot not)
           
protected  void DestinationImpl.handleDeniedMessage(java.lang.String msgId, AgentId replyTo)
          Method used to do specific actions when a message is denied because of a lack of rights.
protected  void AdminTopicImpl.handleDeniedMessage(java.lang.String msgId, AgentId replyTo)
          Method used to send a response when a message is denied because of a lack of rights.
protected  void QueueImpl.handleExpiredNot(AgentId from, ExpiredNot not)
           
 void Destination.init(AgentId adminId, java.util.Properties props)
          Initializes the destination by creating the DestinationItf object.
 void AdminDestinationItf.init(AgentId adminId, java.util.Properties prop)
          Initializes the destination and sets the destination properties.
protected  boolean DestinationImpl.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 DestinationImpl.isLocal(AgentId id)
           
protected  boolean DestinationImpl.isReader(AgentId client)
          Checks the reading permission of a given client agent.
protected  boolean DestinationImpl.isWriter(AgentId client)
          Checks the writing permission of a given client agent.
 void ClusterQueueImpl.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.
 void ClusterQueueImpl.lBMessageGive(AgentId from, LBMessageGive not)
          load balancing message give by an other cluster queue. process ClientMessages, no need to check if sender is writer.
 void ClusterQueueImpl.lBMessageHope(AgentId from, LBMessageHope not)
          load balancing message hope by the "from" queue.
 ClientMessages DistributionTopicImpl.preProcess(AgentId from, ClientMessages cm)
           
 ClientMessages DistributionQueueImpl.preProcess(AgentId from, ClientMessages cm)
           
 ClientMessages DestinationImpl.preProcess(AgentId from, ClientMessages msgs)
          This method is needed to add processing before the standard handling.
 ClientMessages ClusterQueueImpl.preProcess(AgentId from, ClientMessages not)
          overload preProcess(AgentId, ClientMessages) store all msgId in timeTable and visitTable.
 ClientMessages AdminTopicImpl.preProcess(AgentId from, ClientMessages msgs)
          Overrides this DestinationImpl method; ClientMessages notifications hold requests sent by an administrator.
 ClientMessages AcquisitionTopicImpl.preProcess(AgentId from, ClientMessages cm)
          Incoming JMS messages are used for configuration, they are processed by the acquisition module and a null ClientMessages is always returned to the base implementation.
 ClientMessages AcquisitionQueueImpl.preProcess(AgentId from, ClientMessages cm)
          Incoming JMS messages are used for configuration, they are processed by the acquisition module and a null ClientMessages is always returned to the base implementation.
(package private)  void AdminTopicImpl.processAdminRequests(AgentId replyTo, java.lang.String msgId, AdminRequest request, AgentId from)
          Method getting the administration requests from messages, and distributing them to the appropriate reactions.
protected  void DestinationImpl.processSetRight(AgentId user, int right)
          set user right.
 void Topic.react(AgentId from, Notification not)
          Distributes the received notifications to the appropriate reactions.
 void Queue.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 ClusterQueue.react(AgentId from, Notification not)
          Distributes the received notifications to the appropriate reactions.
 void AdminTopic.react(AgentId from, Notification not)
          Distributes the received notifications to the appropriate reactions.
 void AcquisitionTopic.react(AgentId from, Notification not)
           
 void AcquisitionQueue.react(AgentId from, Notification not)
           
 void QueueImpl.receiveRequest(AgentId from, ReceiveRequest not)
          Method implementing the reaction to a ReceiveRequest instance, requesting a message.
 void ClusterQueueImpl.receiveRequest(AgentId from, ReceiveRequest not)
           
static void AdminTopicImpl.registerDest(AgentId id, java.lang.String name, byte type)
          Registers a newly created destination.
protected  void DestinationImpl.replyToTopic(AdminReply reply, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
 void DestinationImpl.requestGroupNot(AgentId from, RequestGroupNot not)
           
 void AdminTopicImpl.requestGroupNot(AgentId from, RequestGroupNot not)
           
 void DestinationImpl.setRight(SetRight request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
          Method implementing the reaction to a SetRightRequest notification requesting rights to be set for a user.
 void DestinationImpl.specialAdminRequest(AgentId from, SpecialAdminRequest not)
          Method implementing the reaction to a SpecialAdminRequest notification requesting the special administration of the destination.
private  void ClusterQueueImpl.storeMsgIdInVisitTable(java.lang.String msgId, AgentId destId)
           
 void TopicImpl.subscribeRequest(AgentId from, SubscribeRequest not)
          Method implementing the reaction to a SubscribeRequest instance.
 void AdminTopicImpl.topicForwardNot(AgentId from, TopicForwardNot not)
          Overrides this TopicImpl method; the forwarded messages contain admin requests and will be processed.
 void DestinationImpl.unknownAgent(AgentId from, UnknownAgent not)
          Method implementing the reaction to an UnknownAgent notification.
 void TopicImpl.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
AcquisitionQueueImpl(AgentId adminId, java.util.Properties properties)
          Constructs an AcquisitionQueueImpl instance.
AcquisitionTopicImpl(AgentId adminId, java.util.Properties properties)
          Constructs an AcquisitionTopicImpl instance.
AdminTopicImpl.DestinationDesc(AgentId id, java.lang.String name, byte type)
           
AdminTopicImpl(AgentId topicId)
          Constructs an AdminTopicImpl instance.
ClusterAck(boolean ok, java.lang.String info, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
          Constructs a ClusterAck instance.
ClusterNot(AgentId topicId)
          Constructs a ClusterNot instance.
ClusterQueueImpl(AgentId adminId, java.util.Properties prop)
          Constructs a ClusterQueueImpl instance.
ClusterTest(java.util.Set friends, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
          Constructs a ClusterTest instance.
DestinationImpl(AgentId adminId, java.util.Properties prop)
          Constructs a DestinationImpl.
DistributionQueueImpl(AgentId adminId, java.util.Properties properties)
          Constructs a DistributionQueueImpl instance.
DistributionTopicImpl(AgentId adminId, java.util.Properties properties)
          Constructs a DistributionTopicImpl instance.
QueueImpl(AgentId adminId, java.util.Properties prop)
          Constructs a QueueImpl instance.
TopicImpl(AgentId adminId, java.util.Properties prop)
          Constructs a TopicImpl instance.
 

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

Fields in org.objectweb.joram.mom.dest.jmsbridge declared as AgentId
protected  AgentId JMSBridgeModule.agentId
          Identifier of the agent using this module.
 

Methods in org.objectweb.joram.mom.dest.jmsbridge with parameters of type AgentId
 void JMSBridgeQueueImpl.bridgeDelivery(AgentId from, JMSBridgeDeliveryNot not)
          Reacts to BridgeDeliveryNot notifications holding a message received from the foreign JMS server.
 void JMSBridgeTopicImpl.bridgeDeliveryNot(AgentId from, JMSBridgeDeliveryNot not)
          Reacts to BridgeDeliveryNot notifications holding a message received from the foreign JMS server.
 DestinationImpl JMSBridgeTopic.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the bridge topic.
 DestinationImpl JMSBridgeQueue.createsImpl(AgentId adminId, java.util.Properties prop)
          Creates the bridge queue.
 void JMSBridgeModule.init(AgentId agentId)
          Initializes the module's parameters.
 ClientMessages JMSBridgeTopicImpl.preProcess(AgentId from, ClientMessages not)
          Method specializing the reaction to a ClientMessages instance.
 ClientMessages JMSBridgeQueueImpl.preProcess(AgentId from, ClientMessages not)
          Method specializing the processing of a ClientMessages instance.
 void JMSBridgeTopic.react(AgentId from, Notification not)
          Specializes this TopicImpl method for processing the specific bridge notifications.
 void JMSBridgeQueue.react(AgentId from, Notification not)
          Specializes this QueueImpl method for processing the specific bridge notifications.
 void JMSBridgeQueueImpl.receiveRequest(AgentId from, ReceiveRequest not)
          Method specializing the reaction to a ReceiveRequest instance, requesting a message.
 void JMSBridgeTopicImpl.topicForwardNot(AgentId from, TopicForwardNot not)
          Method specializing the reaction to a TopicForwardNot instance, carrying messages forwarded by a cluster fellow or a hierarchical son.
 

Constructors in org.objectweb.joram.mom.dest.jmsbridge with parameters of type AgentId
JMSBridgeQueueImpl(AgentId adminId, java.util.Properties prop)
          Constructs a BridgeQueueImpl instance.
JMSBridgeTopicImpl(AgentId adminId, java.util.Properties prop)
          Constructs a BridgeTopicImpl instance.
 

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

Fields in org.objectweb.joram.mom.notifications declared as AgentId
private  AgentId FwdAdminRequestNot.replyTo
          The JMS destination to send the reply
 AgentId ReceiveRequest.requester
          Identifier of the client requesting a message, set by the queue if storing the request.
 

Methods in org.objectweb.joram.mom.notifications that return AgentId
 AgentId ClientMessages.getDMQId()
          Returns the identifier of the producer's dead message queue, if any.
 AgentId[] GetProxyIdListNot.getIds()
           
 AgentId GetProxyIdNot.getProxyId()
           
 AgentId FwdAdminRequestNot.getReplyTo()
          Returns the JMS destination to send the reply.
 

Methods in org.objectweb.joram.mom.notifications with parameters of type AgentId
 void GetProxyIdNot.Return(AgentId proxyId)
           
 void GetProxyIdListNot.Return(AgentId[] proxyIds)
           
 void TopicMsgsReply.setDMQId(AgentId dmqId)
          Sets the identifier of the producer's dead message queue.
 void ClientMessages.setDMQId(AgentId dmqId)
          Sets the identifier of the producer's dead message queue.
 

Constructors in org.objectweb.joram.mom.notifications with parameters of type AgentId
FwdAdminRequestNot(AdminRequest request, AgentId replyTo, java.lang.String requestMsgId)
          Creates a new FwdAdminRequestNot to send to a remote AdminTopic.
FwdAdminRequestNot(AdminRequest request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
          Creates a new FwdAdminRequestNot to send to an administered target (user or destination).
 

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

Fields in org.objectweb.joram.mom.proxies declared as AgentId
private  AgentId ProxyImpl.dmqId
          Identifier of this proxy dead message queue, null for DMQ not set.
private  AgentId ClientSubscription.dmqId
          Identifier of the subscriber's dead message queue, null for DMQ not set.
private  AgentId MultiCnxSync.proxyId
           
private  AgentId ClientSubscription.proxyId
          The proxy's agent identifier.
private  AgentId ClientContext.proxyId
          The proxy's agent identifier.
private  AgentId AdminNotification.proxyId
          The proxy's AgentId identifier.
private  AgentId ClientSubscription.topicId
          The topic identifier.
 

Methods in org.objectweb.joram.mom.proxies that return AgentId
 AgentId ProxyAgentItf.getId()
          Returns the proxy's AgentId identifier.
 AgentId AdminNotification.getProxyId()
          Returns the AgentId of the proxy.
 AgentId ClientSubscription.getTopicId()
          Returns the identifier of the subscription topic.
 

Methods in org.objectweb.joram.mom.proxies with parameters of type AgentId
(package private)  void ClientContext.addDeliveringQueue(AgentId queueId)
          Adds the identifier of a delivering queue.
(package private)  void ClientContext.addTemporaryDestination(AgentId destId)
          Adds a temporary destination identifier.
private  void ProxyImpl.deleteTemporaryDestination(AgentId destId)
           
private  void ProxyImpl.doFwd(AgentId from, AbstractReplyNot rep)
          Distributes the JMS replies to the appropriate reactions.
private  void ProxyImpl.doFwd(AgentId from, QueueMsgReply rep)
          Actually forwards a QueueMsgReply coming from a destination as a ConsumerMessages destinated to the requesting client.
private  void ProxyImpl.doFwd(AgentId from, TopicMsgsReply rep)
          Method implementing the proxy reaction to a TopicMsgsReply holding messages published by a topic.
private  void ProxyImpl.doReact(AgentId from, ExceptionReply rep)
          Actually forwards an ExceptionReply coming from a destination as a MomExceptionReply destinated to the requesting client.
private  void ProxyImpl.doReact(ClearSubscription request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
private  void ProxyImpl.doReact(DeleteSubscriptionMessage request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
private  void ProxyImpl.doReact(GetSubscription request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
private  void ProxyImpl.doReact(GetSubscriptionMessage request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
private  void ProxyImpl.doReact(GetSubscriptionMessageIds request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
private  void ProxyImpl.doReact(GetSubscriptions request, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
static MultiCnxSync ConnectionManager.getMultiCnxSync(AgentId proxyId)
           
 void UserAgent.react(AgentId from, Notification not)
          Overrides the Agent class react method for providing the JMS client proxy with its specific behaviour.
 void ProxyImpl.react(AgentId from, Notification not)
          Distributes the received notifications to the appropriate reactions.
(package private)  void ClientSubscription.reactivate(int contextId, int reqId, AgentId topicId, java.lang.String selector, boolean noLocal)
          Reactivates the subscription.
(package private)  void ClientContext.removeTemporaryDestination(AgentId destId)
          Removes a temporary destination identifier.
private  void ProxyImpl.replyToTopic(AdminReply reply, AgentId replyTo, java.lang.String requestMsgId, java.lang.String replyMsgId)
           
 void UserAgent.sendNot(AgentId to, Notification not)
          Sends a notification to the specified agent.
 void ProxyAgentItf.sendNot(AgentId to, Notification not)
          Sends a notification to a given agent.
static void ConnectionManager.sendToProxy(AgentId proxyId, int cnxKey, AbstractJmsRequest req, java.lang.Object msg)
           
(package private)  void ClientSubscription.setDMQId(AgentId dmqId)
          Sets the subscription's dead message queue identifier.
private  boolean ProxyImpl.updateSubscriptionToTopic(AgentId topicId, int contextId, int requestId)
          Updates the proxy's subscription to a topic.
private  boolean ProxyImpl.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
AdminNotification(AgentId proxyId, Identity identity)
          Constructs an AdminNotification instance.
ClientContext(AgentId proxyId, int id)
          Constructs a ClientContext instance.
ClientSubscription(AgentId proxyId, int contextId, int reqId, boolean durable, AgentId topicId, java.lang.String name, java.lang.String selector, boolean noLocal, AgentId dmqId, int threshold, int nbMaxMsg, java.util.Map messagesTable)
          Constructs a ClientSubscription instance.
MultiCnxSync(AgentId pid)
           
 

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

Fields in org.objectweb.joram.mom.proxies.soap declared as AgentId
(package private)  AgentId SoapProxyService.ProxyConnectionContext.proxyId
           
 

Constructors in org.objectweb.joram.mom.proxies.soap with parameters of type AgentId
SoapProxyService.ProxyConnectionContext(AgentId proxyId, Queue replyQueue)
           
 

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

Fields in org.objectweb.joram.mom.proxies.tcp declared as AgentId
private  AgentId TcpReader.proxyId
           
private  AgentId TcpConnection.proxyId
           
 

Methods in org.objectweb.joram.mom.proxies.tcp that return AgentId
 AgentId TcpConnection.getProxyId()
           
 

Methods in org.objectweb.joram.mom.proxies.tcp with parameters of type AgentId
(package private)  TcpConnection TcpProxyService.getConnection(AgentId proxyId, int key)
           
 

Constructors in org.objectweb.joram.mom.proxies.tcp with parameters of type AgentId
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)
          Creates a new reader.
 

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

Fields in org.objectweb.joram.mom.util declared as AgentId
private  AgentId DMQManager.destDmqId
           
private  AgentId DMQManager.senderId
           
 

Constructors in org.objectweb.joram.mom.util with parameters of type AgentId
DMQManager(AgentId currentDestDmq, AgentId senderId)
          Creates a DMQManager.
DMQManager(AgentId specificDmq, AgentId currentDestDmq, AgentId senderId)
          Creates a DMQManager.
 



Copyright © 2010 ScalAgent D.T.. All Rights Reserved.