|
|||||||||
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.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 |
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 |
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. |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |