|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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.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.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 |
---|
Methods in com.scalagent.joram.mom.dest.ftp with parameters of type AgentId | |
---|---|
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 | |
---|---|
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 |
---|
Methods in com.scalagent.joram.mom.dest.scheduler with parameters of type AgentId | |
---|---|
void |
SchedulerQueue.react(AgentId from,
Notification not)
|
Constructors in com.scalagent.joram.mom.dest.scheduler with parameters of type AgentId | |
---|---|
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
|
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 |
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 . |
AgentId |
ExpiredNot.getToAgentId()
|
static AgentId |
AgentId.localId(short sid)
|
Methods in fr.dyade.aaa.agent with parameters of type AgentId | |
---|---|
void |
RoleMultiple.addListener(AgentId target)
Adds an agent in the listeners list. |
boolean |
RoleMultiple.contains(AgentId id)
Tests if the specified agent id belongs to role multiple. |
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. |
void |
Agent.deploy(AgentId reply)
Deploys a new agent. |
java.lang.Object[] |
SyncNotification.invoke(AgentId to)
|
java.lang.Object[] |
SyncNotification.Context.invoke(AgentId to)
|
void |
Agent.react(AgentId from,
Notification not)
Defines the reaction of the agent when receiving a notification. |
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. |
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 | |
---|---|
AgentCreateReply(AgentId agent)
|
|
AgentCreateRequest(Agent agent,
AgentId reply)
|
|
AgentDeleteRequest(AgentId reply)
|
|
AgentDeleteRequest(AgentId reply,
java.lang.Object extraInformation)
|
|
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 |
---|
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)
|
protected JndiReply |
ReplicationManager.invokeOwner(AgentId owner,
RequestContext reqCtx)
Overrides the JndiServer behavior. |
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 |
---|
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 |
---|
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)
|
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)
|
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.mom.dest |
---|
Fields in org.objectweb.joram.mom.dest declared as AgentId | |
---|---|
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. |
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 |
Queue.getDefaultDMQId()
Static method returning the default DMQ identifier. |
AgentId |
Destination.getDMQAgentId()
|
AgentId |
AdminTopic.DestinationDesc.getId()
|
Methods in org.objectweb.joram.mom.dest with parameters of type AgentId | |
---|---|
protected void |
Queue.abortReceiveRequest(AgentId from,
AbortReceiveRequest not)
|
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. |
protected void |
Destination.clientMessages(AgentId from,
ClientMessages not)
Method implementing the reaction to a ClientMessages
notification holding messages sent by a client. |
protected void |
Destination.deleteNot(AgentId from,
DeleteNot not)
Method implementing the reaction to a DeleteNot
notification requesting the deletion of the destination. |
void |
AdminTopic.deleteNot(AgentId from,
DeleteNot not)
Overrides this Destination method. |
protected void |
Queue.denyRequest(AgentId from,
DenyRequest not)
Method implementing the reaction to a DenyRequest
instance, requesting messages to be denied. |
protected void |
Topic.doClientMessages(AgentId from,
ClientMessages not)
Method specifically processing a ClientMessages instance. |
protected void |
Queue.doClientMessages(AgentId from,
ClientMessages not)
Method specifically processing a ClientMessages instance. |
protected abstract void |
Destination.doClientMessages(AgentId from,
ClientMessages not)
|
protected void |
Topic.doRightRequest(AgentId user,
int right)
Method specifically processing a SetRightRequest instance. |
protected void |
Queue.doRightRequest(AgentId user,
int right)
Method specifically processing a SetRightRequest instance. |
protected abstract void |
Destination.doRightRequest(AgentId user,
int right)
This method is needed for right revocation. |
protected void |
Destination.forward(AgentId to,
Notification not)
|
protected void |
Destination.getRights(AgentId from,
GetRightsRequestNot not)
Method implementing the reaction to a GetRightsRequest
notification requesting the rights about this destination. |
void |
Topic.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
|
void |
Queue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
|
protected void |
Destination.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
|
void |
ClusterQueue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
|
protected void |
Destination.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 |
AdminTopic.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 |
Queue.handleExpiredNot(AgentId from,
ExpiredNot 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. |
ClientMessages |
DistributionTopic.preProcess(AgentId from,
ClientMessages cm)
|
ClientMessages |
DistributionQueue.preProcess(AgentId from,
ClientMessages cm)
|
protected ClientMessages |
Destination.preProcess(AgentId from,
ClientMessages msgs)
This method is needed to add processing before the standard handling. |
ClientMessages |
ClusterQueue.preProcess(AgentId from,
ClientMessages not)
overload preProcess(AgentId, ClientMessages) store all msgId in timeTable and visitTable. |
protected ClientMessages |
AdminTopic.preProcess(AgentId from,
ClientMessages msgs)
Overrides this Destination method; |
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. |
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. |
protected void |
Destination.processAdminCommand(AdminCommandRequest request,
AgentId replyTo,
java.lang.String requestMsgId)
Proccess an admin command. |
protected void |
Destination.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)
|
protected void |
Queue.receiveRequest(AgentId from,
ReceiveRequest not)
Method implementing the reaction to a ReceiveRequest
instance, requesting a message. |
void |
ClusterQueue.receiveRequest(AgentId from,
ReceiveRequest not)
|
static void |
AdminTopic.registerDest(AgentId id,
java.lang.String name,
byte type)
Registers a newly created destination. |
protected void |
Destination.replyToTopic(AdminReply reply,
AgentId replyTo,
java.lang.String requestMsgId,
java.lang.String replyMsgId)
|
protected void |
Destination.requestGroupNot(AgentId from,
RequestGroupNot not)
|
protected void |
AdminTopic.requestGroupNot(AgentId from,
RequestGroupNot not)
|
void |
Destination.setAdminId(AgentId adminId)
Sets the administrator of the destination. |
protected void |
Destination.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. |
protected void |
Topic.subscribeRequest(AgentId from,
SubscribeRequest not)
Method implementing the reaction to a SubscribeRequest
instance. |
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 |
AdminTopic.topicForwardNot(AgentId from,
TopicForwardNot not)
Overrides this Topic method; the forwarded messages
contain admin requests and will be processed. |
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 | |
---|---|
AdminTopic.DestinationDesc(AgentId id,
java.lang.String name,
byte type)
|
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 |
JMSBridgeModule.init(AgentId agentId)
Initializes the module's parameters. |
ClientMessages |
JMSBridgeTopic.preProcess(AgentId from,
ClientMessages not)
Method specializing the reaction to a ClientMessages
instance. |
ClientMessages |
JMSBridgeQueue.preProcess(AgentId from,
ClientMessages not)
Method specializing the processing of a ClientMessages
instance. |
void |
JMSBridgeTopic.react(AgentId from,
Notification not)
Specializes this Topic method for processing the
specific bridge notifications. |
void |
JMSBridgeQueue.react(AgentId from,
Notification not)
Specializes this Queue method for processing the
specific bridge notifications. |
void |
JMSBridgeQueue.receiveRequest(AgentId from,
ReceiveRequest not)
Method specializing the reaction to a ReceiveRequest
instance, requesting a message. |
void |
JMSBridgeTopic.topicForwardNot(AgentId from,
TopicForwardNot not)
Method specializing the reaction to a TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son. |
Uses of AgentId in org.objectweb.joram.mom.notifications |
---|
Fields in org.objectweb.joram.mom.notifications declared as AgentId | |
---|---|
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. |
AgentId |
ClusterJoinNot.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 | |
---|---|
ClusterJoinNot(java.util.Set cluster,
AgentId replyTo,
java.lang.String requestMsgId,
java.lang.String replyMsgId)
|
|
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 |
---|
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. |
Methods in org.objectweb.joram.mom.proxies with parameters of type AgentId | |
---|---|
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 |
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)
|
Constructors in org.objectweb.joram.mom.proxies with parameters of type AgentId | |
---|---|
MultiCnxSync(AgentId pid)
|
Uses of AgentId in org.objectweb.joram.mom.proxies.tcp |
---|
Methods in org.objectweb.joram.mom.proxies.tcp that return AgentId | |
---|---|
AgentId |
TcpConnection.getProxyId()
|
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 |
---|
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |