Package | Description |
---|---|
com.scalagent.joram.mom.dest.ftp | |
com.scalagent.joram.mom.dest.scheduler | |
fr.dyade.aaa.agent | |
fr.dyade.aaa.jndi2.distributed | |
fr.dyade.aaa.jndi2.server | |
org.objectweb.joram.client.jms.local | |
org.objectweb.joram.mom.dest |
The
org.objectweb.joram.mom.dest package holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM. |
org.objectweb.joram.mom.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 | |
org.ow2.joram.jakarta.jms.local | |
org.ow2.joram.mom.amqp |
Modifier and Type | Field and Description |
---|---|
private AgentId |
FtpThread.destId |
private AgentId |
FtpQueue.dmq |
private AgentId |
FtpThread.dmqId |
Modifier and Type | Method and Description |
---|---|
ClientMessages |
FtpQueue.preProcess(AgentId from,
ClientMessages not) |
void |
FtpQueue.react(AgentId from,
Notification not) |
Constructor and Description |
---|
FtpThread(TransferItf transfer,
FtpMessage ftpMsg,
AgentId destId,
AgentId dmqId,
int clientContext,
int requestId,
String user,
String pass,
String path) |
Modifier and Type | Field and Description |
---|---|
private AgentId |
SchedulerQueueTask.schedulerQueue |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerQueue.react(AgentId from,
Notification not) |
Constructor and Description |
---|
SchedulerQueueTask(AgentId schedulerQueue) |
Modifier and Type | Field and Description |
---|---|
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 |
private AgentId |
MessageSoftRef.deadNotAgentId
The agent responsible of treating the notification when it expires.
|
(package private) AgentId |
Notification.deadNotificationAgentId
The agentId identifying the agent to which the notification is sent when it
is expired.
|
(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.
|
private AgentId |
UnknownAgentException.unknownAgentId |
Modifier and Type | Field and Description |
---|---|
(package private) Hashtable<AgentId,Agent> |
Engine.agents
This table is used to maintain a list of agents already in memory
using the AgentId as primary key.
|
(package private) Vector<AgentId> |
Engine.fixedAgentIdList
Vector containing id's of all fixed agents.
|
private Vector<AgentId> |
RoleMultiple.list |
Modifier and Type | Method and Description |
---|---|
static AgentId |
AgentId.factoryId(short sid)
Returns the
AgentId for a remote factory agent. |
static AgentId |
AgentId.fromString(String str)
Parses the string argument as an
AgentId . |
AgentId |
MessageSoftRef.getDeadNotAgentId()
Returns the agent responsible of treating the notification when it expires.
|
AgentId |
Notification.getDeadNotificationAgentId() |
AgentId |
AgentCreateRequest.getDeploy() |
AgentId |
Message.getFrom() |
AgentId |
ExpiredNot.getFromAgentId() |
AgentId |
Agent.getId()
Returns the global unique identifier of the agent.
|
AgentId |
Role.getListener()
Returns the wrapped
AgentId . |
(package private) AgentId[] |
Engine.getLoadedAgentIdlist()
Method used for debug and monitoring.
|
AgentId |
AgentEngineContextImpl.getLocalAgentId()
Returns the local agent id.
|
AgentId |
AgentEngineContext.getLocalAgentId()
Returns the local agent id.
|
AgentId |
Message.getTo() |
AgentId |
ExpiredNot.getToAgentId() |
AgentId |
UnknownAgentException.getUnknownAgentId()
Returns the unknown agent identifier.
|
static AgentId |
AgentId.localId(short sid) |
Modifier and Type | Method and Description |
---|---|
Enumeration<AgentId> |
RoleMultiple.getListeners()
Gets the listeners list as an
Enumeration of AgentId objects. |
Modifier and Type | Method and Description |
---|---|
(package private) void |
Engine.addFixedAgentId(AgentId id)
Adds an
AgentId in the fixedAgentIdList
Vector . |
void |
RoleMultiple.addListener(AgentId target)
Adds an agent in the listeners list.
|
(package private) static Message |
Message.alloc(AgentId from,
AgentId to,
Notification not)
Allocates a message from the pool.
|
boolean |
RoleMultiple.contains(AgentId id)
Tests if the specified agent id belongs to
role multiple.
|
void |
Engine.createAgent(AgentId id,
Agent agent)
Creates and initializes an agent.
|
void |
AgentEngine.createAgent(AgentId id,
Agent agent)
Creates and initializes an agent.
|
Message |
AgentEngineContextImpl.createMessage(AgentId from,
AgentId to,
Notification not)
Creates a message.
|
Message |
AgentEngineContext.createMessage(AgentId from,
AgentId to,
Notification not)
Creates a message.
|
void |
Agent.delete(AgentId agent)
Permits this agent to destroy itself.
|
void |
Agent.delete(AgentId agent,
Object extraInformation)
Permits this agent to destroy itself.
|
void |
Engine.deleteAgent(AgentId id)
Deletes an agent.
|
void |
AgentEngine.deleteAgent(AgentId agent)
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.
|
void |
AgentEngineContextImpl.directSendTo(AgentId to,
Notification not)
Sends a notification to the specified destination
with a local id.
|
void |
AgentEngineContext.directSendTo(AgentId to,
Notification not)
Sends a notification to the specified destination
with a local id.
|
String |
Engine.dumpAgent(AgentId id)
Returns a string representation of the specified agent.
|
String |
AgentEngine.dumpAgent(AgentId id)
Returns a string representation of the specified agent.
|
void |
AgentEngineContextImpl.initializeAgent(AgentId id,
Agent agent)
Initializes an agent after creation.
|
void |
AgentEngineContext.initializeAgent(AgentId id,
Agent agent)
Initializes an agent after creation.
|
private void |
Agent.initState(String name,
boolean fixed,
AgentId id) |
Object[] |
SyncNotification.invoke(AgentId to) |
Object[] |
SyncNotification.Context.invoke(AgentId to) |
Object[] |
SyncNotification.invoke(AgentId to,
long timeout) |
Object[] |
SyncNotification.Context.invoke(AgentId to,
long timeout) |
(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.
|
Agent |
AgentEngineContextImpl.loadAgent(AgentId id)
Loads the specified agent.
|
Agent |
AgentEngineContext.loadAgent(AgentId id)
Loads the specified agent.
|
void |
Engine.push(AgentId from,
AgentId to,
Notification not)
Push a new message in temporary queue until the end of current reaction.
|
void |
AgentEngine.push(AgentId from,
AgentId to,
Notification not)
Puts a notification in the output queue.
|
void |
Engine.push(AgentId to,
Notification not)
Push a new message in temporary queue until the end of current reaction.
|
void |
AgentEngine.push(AgentId to,
Notification not)
Puts a notification in the output queue.
|
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 . |
Constructor and Description |
---|
Agent(String name,
boolean fixed,
AgentId id)
Constructor used to build "system" agents like
AgentFactory . |
AgentCreateReply(AgentId agent) |
AgentCreateRequest(Agent agent,
AgentId reply) |
AgentDeleteRequest(AgentId reply) |
AgentDeleteRequest(AgentId reply,
Object extraInformation) |
AgentFactory(AgentId factoryId)
Allocates a new
AgentFactory agent. |
DeleteAck(AgentId agent) |
DeleteAck(AgentId agent,
int status) |
DeleteAck(AgentId agent,
Object extraInformation) |
DeleteAck(AgentId agent,
Throwable exc) |
DeleteNot(AgentId reply) |
ExceptionNotification(AgentId agent,
Notification not,
Exception exc)
Allocates a new
ExceptionNotification notification. |
ExpiredNot(Notification expiredNot,
AgentId from,
AgentId to)
Builds a notification carrying an expired notification.
|
Role(String name,
AgentId listener)
Creates a new role with the specified name and AgentId.
|
UnknownAgent(AgentId agent,
Notification not)
Allocates a new
UnknownAgent notification. |
UnknownAgentException(String s,
AgentId unknownAgentId)
Constructs a new
UnknownAgentException with the
specified detail message and agent identifier. |
UnknownNotification(AgentId agent,
Notification not)
Allocates a new
UnknownNotification notification. |
WakeUpTask(AgentId id,
Class<?> wakeUpNotClass,
long period)
Creates a new WakeUpTask and schedules it.
|
Modifier and Type | Field and Description |
---|---|
private AgentId[] |
InitJndiServerNot.jndiServerIds |
private AgentId |
ReplicationManager.rootOwnerId
Identifier of the server that owns the root naming context.
|
Modifier and Type | Method and Description |
---|---|
static AgentId |
DistributedJndiServer.getDefault()
Returns the default JndiServer id on the local agent server.
|
static AgentId |
DistributedJndiServer.getDefault(short serverId)
Returns the default JndiServer id on the given agent server.
|
AgentId[] |
InitJndiServerNot.getJndiServerIds() |
protected AgentId |
ReplicationManager.getRootOwnerId()
Overrides the
JndiServer behavior. |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
InitJndiServerNot(AgentId[] jndiServerIds,
NamingContextInfo[] contexts,
boolean isRequest) |
Modifier and Type | Field and Description |
---|---|
private AgentId |
AgentRequestContext.from |
private AgentId |
TcpServer.serverId |
Modifier and Type | Method and Description |
---|---|
static AgentId |
JndiServer.getDefault()
Returns the default JndiServer id on the local agent server.
|
static AgentId |
JndiServer.getDefault(short serverId)
Returns the default JndiServer id on the given agent server.
|
AgentId |
AgentRequestContext.getFrom() |
AgentId |
RequestManager.getId() |
protected AgentId |
RequestManager.getRootOwnerId()
Returns the root naming context owner identifier.
|
AgentId |
TcpServer.getServerId() |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
AgentRequestContext(JndiRequest request,
AgentId from,
boolean doReply) |
TcpServer(ServerSocket listen,
int poolSize,
AgentId serverId) |
Modifier and Type | Field and Description |
---|---|
private AgentId |
LocalRequestChannel.proxyId |
Modifier and Type | Field and Description |
---|---|
private AgentId |
Destination.adminId
Identifier of the destination's administrator.
|
(package private) static AgentId |
AdminTopic.adminId |
private AgentId |
QueueDelivery.consumerId |
(package private) static AgentId |
Queue.defaultDMQId
Static value holding the default DMQ identifier for a server.
|
protected AgentId |
Destination.dmqId
Identifier of the dead message queue this destination must send its
dead messages to, if any.
|
protected AgentId |
Topic.fatherId
Identifier of this topic's father, if any.
|
(package private) AgentId |
ElasticTopic.TopicDesc.id |
private AgentId |
AdminTopic.DestinationDesc.id |
private AgentId |
NotificationDistributionHandler.remoteDestinationID
the queue to send the notification to
|
private AgentId |
AliasQueue.remoteDestinationID
The queue to send the notification to
|
Modifier and Type | Field and Description |
---|---|
private ArrayList<AgentId> |
AliasInQueue.destinations |
private Map<String,AgentId> |
AdminTopic.proxiesTable
Table holding the TCP users proxies identifiers.
|
private Map<String,AgentId> |
AdminTopic.requestsTable
Table keeping the administrator's requests.
|
Modifier and Type | Method and Description |
---|---|
AgentId |
QueueDelivery.getConsumerId() |
static AgentId |
AdminTopic.getDefault()
Gets the identifier of the default administration topic on the
current server.
|
static AgentId |
AdminTopic.getDefault(short serverId)
Gets the identifier of the default administration topic on a given server.
|
static AgentId |
Queue.getDefaultDMQId()
Static method returning the default DMQ identifier.
|
AgentId |
Destination.getDMQAgentId() |
AgentId |
AdminTopic.DestinationDesc.getId() |
private AgentId |
AdminTopic.getProxyId(Identity identity,
String inaddr)
Method used by
ConnectionManager proxies to check their
clients identification. |
static AgentId |
AdminTopic.lookupUser(String name)
Retrieves an existing user
|
Modifier and Type | Method and Description |
---|---|
protected void |
Queue.abortReceiveRequest(AgentId from,
AbortReceiveRequest not) |
private void |
AcquisitionTopic.acquisitionNot(AgentId from,
AcquisitionNot not)
This method process messages from the acquisition module.
|
private void |
AdminTopic.broadcastRequest(AdminRequest request,
int avoidServerId,
AgentId replyTo,
String msgId)
Sends the administration request to AdminTopic of all servers except the given one.
|
protected void |
Queue.browseRequest(AgentId from,
BrowseRequest not)
Method implementing the queue reaction to a
BrowseRequest
instance, requesting an enumeration of the messages on the queue. |
private void |
Queue.clearQueue(AgentId replyTo,
String requestMsgId,
String replyMsgId) |
protected void |
Destination.clientMessages(AgentId from,
ClientMessages not)
Method implementing the reaction to a
ClientMessages
notification holding messages sent by a client. |
private void |
Topic.clusterRemove(AgentId topic)
Remove the specified topic from current cluster.
|
private void |
ClusterQueue.clusterRemove(AgentId queue)
Remove the specified queue from current cluster.
|
private AdminTopic.DestinationDesc |
AdminTopic.createDestination(String destName,
AgentId adminId,
Properties properties,
byte type,
String className,
String requestClassName,
StringBuffer strbuf)
Instantiating the destination class or retrieving the destination.
|
static AdminTopic.DestinationDesc |
AdminTopic.createDestinationAndSave(String destName,
AgentId adminId,
Properties properties,
byte type,
String className,
String requestClassName,
StringBuffer strbuf)
Deprecated.
|
protected TopicForwardNot |
Topic.createTopicForward(AgentId destId,
ClientMessages messages,
boolean fromCluster) |
static void |
AdminTopic.CreateUserAndSave(CreateUserRequest request,
AgentId replyTo,
String msgId)
Deprecated.
|
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. |
private void |
Queue.deleteQueueMessage(DeleteQueueMessage request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
protected void |
Queue.denyRequest(AgentId from,
DenyRequest not)
Method implementing the reaction to a
DenyRequest
instance, requesting messages to be denied. |
private void |
AdminTopic.distributeReply(AgentId to,
String msgId,
AdminReply reply)
Actually sends an
AdminReply object to an identified
destination. |
protected void |
Topic.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest)
Method specifically processing a
ClientMessages instance. |
protected void |
Queue.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest)
Method specifically processing a
ClientMessages instance. |
protected void |
ElasticTopic.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest) |
protected abstract void |
Destination.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest) |
private void |
Topic.doClientMessages(AgentId from,
ClientMessages not,
boolean fromCluster,
boolean throwsExceptionOnFullDest) |
private void |
AdminTopic.doProcess(AddDomainRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Adds a new domain to the configuration.
|
private void |
AdminTopic.doProcess(AddServerRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Adds a server to the configuration.
|
private void |
AdminTopic.doProcess(AdminCommandRequest request,
AgentId replyTo,
String requestMsgId)
Process an admin command.
|
private void |
AdminTopic.doProcess(AgentId replyTo,
String msgId) |
private void |
AdminTopic.doProcess(CreateDestinationRequest request,
AgentId replyTo,
String msgId)
Processes a
CreateDestinationRequest instance
requesting the creation of a destination. |
private void |
AdminTopic.doProcess(CreateUserRequest request,
AgentId replyTo,
String msgId)
Processes a
CreateUserRequest instance requesting the
creation of a UserAgent for a given user. |
private void |
AdminTopic.doProcess(DeleteDestination request,
AgentId replyTo,
String msgId)
Processes a
DeleteDestination instance requesting the
deletion of a destination. |
private void |
AdminTopic.doProcess(DeleteUser request,
AgentId replyTo,
String msgId)
Processes a
DeleteUser instance requesting the deletion
of a user. |
private void |
AdminTopic.doProcess(DestinationAdminRequest request,
AgentId replyTo,
String msgId)
Processes a
DestinationRequest request by
forwarding it to its target destination, if local. |
private void |
AdminTopic.doProcess(GetConfigRequest request,
AgentId replyTo,
String msgId)
Gets the current configuration.
|
private void |
AdminTopic.doProcess(GetDestinationsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetDestinations request by sending
registered destinations. |
private void |
AdminTopic.doProcess(GetDMQSettingsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetDMQSettings request either by
processing it and sending back the default DMQ settings, or by
forwarding it to its target destination or proxy. |
private void |
AdminTopic.doProcess(GetDomainNames request,
AgentId replyTo,
String msgId) |
private void |
AdminTopic.doProcess(GetJMXAttsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetJMXAtts request or forwards it to its target
destination if needed. |
private void |
AdminTopic.doProcess(GetRightsRequest request,
AgentId replyTo,
String msgId)
Processes a
GetRightsRequest request by forwarding it
to its target destination, if local. |
private void |
AdminTopic.doProcess(GetServersIdsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetServersIds request by sending
the list of the platform servers' ids. |
private void |
AdminTopic.doProcess(GetStatsRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetStat request or forwards it to its target
destination if needed. |
private void |
AdminTopic.doProcess(GetUsersRequest request,
AgentId replyTo,
String msgId)
Processes a
Monitor_GetUsers request by sending the
users table. |
private void |
AdminTopic.doProcess(RemoveDomainRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Removes a domain in the configuration.
|
private void |
AdminTopic.doProcess(RemoveServerRequest request,
AgentId replyTo,
String msgId,
AgentId from)
Removes a server in the configuration.
|
private void |
AdminTopic.doProcess(SetDMQRequest request,
AgentId replyTo,
String msgId)
Processes a
SetDMQ request requesting a given queue to be set as
the DMQ of a given destination or user. |
private void |
AdminTopic.doProcess(SetThresholdRequest request,
AgentId replyTo,
String msgId)
Processes a
SetThreshold request requesting a given threshold value to be set
as the threshold of a given destination or user. |
private void |
AdminTopic.doProcess(StopServerRequest request,
AgentId replyTo,
String msgId)
Processes a
StopServerRequest instance requesting to stop
a given server. |
private void |
AdminTopic.doProcess(UpdateUser request,
AgentId replyTo,
String msgId)
Processes an
UpdateUser instance requesting to modify the
identification of a user. |
private void |
AdminTopic.doProcess(UserAdminRequest request,
AgentId replyTo,
String requestMsgId)
Handle administration request about user.
|
protected 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 |
Topic.forwardMessages(AgentId from,
ClientMessages messages)
Actually forwards a list of messages to the father or the cluster
fellows, if any.
|
protected void |
Topic.forwardMessages(AgentId from,
ClientMessages messages,
boolean fromCluster) |
private void |
Queue.getQueueMessage(GetQueueMessage request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
private void |
Queue.getQueueMessageIds(AgentId replyTo,
String requestMsgId,
String replyMsgId) |
protected void |
Destination.getRights(AgentId from,
GetRightsRequestNot not)
Method implementing the reaction to a
GetRightsRequest
notification requesting the rights about this destination. |
void |
Topic.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
Queue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
ElasticTopic.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
This method handles the scaling operations.
|
protected void |
Destination.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
ClusterQueue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
AliasInQueue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
private void |
ElasticTopic.handleClientSubscriptionNot(AgentId from,
ClientSubscriptionNot not)
If root, redirects subscriptions to proper topic.
|
protected void |
Destination.handleDeniedMessage(String msgId,
AgentId replyTo)
Method used to do specific actions when a message is denied because of a
lack of rights.
|
protected void |
AdminTopic.handleDeniedMessage(String msgId,
AgentId replyTo)
Method used to send a response when a message is denied because of a lack
of rights.
|
protected void |
Queue.handleExpiredNot(AgentId from,
ExpiredNot not) |
protected void |
AliasQueue.handleExpiredNot(AgentId from,
ExpiredNot not) |
protected void |
AliasInQueue.handleExpiredNot(AgentId from,
ExpiredNot not) |
protected void |
AliasInQueue.handlePongNot(AgentId from,
PongNot not) |
protected boolean |
Destination.isAdministrator(AgentId client)
Checks the administering permission of a given client agent.
|
static boolean |
AdminTopic.isAdminTopicId(AgentId id)
Returns true if the given AgentId is the unique identifier of an AdminTopic
agent.
|
protected boolean |
Destination.isLocal(AgentId id) |
protected boolean |
Destination.isReader(AgentId client)
Checks the reading permission of a given client agent.
|
protected boolean |
Destination.isWriter(AgentId client)
Checks the writing permission of a given client agent.
|
private void |
ClusterQueue.lBCycleLife(AgentId from,
LBCycleLife not)
If the messages are not consumed by an other cluster's queue
in a period of time, try to consume in this queue.
|
private void |
ClusterQueue.lBMessageGive(AgentId from,
LBMessageGive not)
load balancing message give by an other cluster queue. process
ClientMessages, no need to check if sender is writer.
|
private void |
ClusterQueue.lBMessageHope(AgentId from,
LBMessageHope not)
load balancing message hope by the "from" queue.
|
ClientMessages |
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.
|
ClientMessages |
AliasQueue.preProcess(AgentId from,
ClientMessages cm) |
ClientMessages |
AliasInQueue.preProcess(AgentId from,
ClientMessages cm) |
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,
String requestMsgId)
Proccess an admin command.
|
private void |
AdminTopic.processAdminRequests(AgentId replyTo,
String msgId,
AdminRequest request,
AgentId from)
Method getting the administration requests from messages, and
distributing them to the appropriate reactions.
|
(package private) void |
Queue.processDeliveryTime(AgentId from,
QueueDeliveryTimeNot not) |
protected void |
Topic.processMessages(AgentId from,
ClientMessages not)
Actually processes the distribution of the received messages to the
valid subscriptions by sending a
TopicMsgsReply notification
to the valid subscribers. |
protected void |
DistributionQueue.processSetRight(AgentId user,
int right) |
protected void |
Destination.processSetRight(AgentId user,
int right)
set user right.
|
protected void |
AliasQueue.processSetRight(AgentId user,
int right) |
protected void |
AliasInQueue.processSetRight(AgentId user,
int 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 |
ElasticTopic.react(AgentId from,
Notification not) |
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 |
AliasQueue.react(AgentId from,
Notification not) |
void |
AliasInQueue.react(AgentId from,
Notification not) |
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,
String name,
byte type)
Registers a newly created destination.
|
protected void |
Destination.replyToTopic(AdminReply reply,
AgentId replyTo,
String requestMsgId,
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,
String requestMsgId,
String replyMsgId)
Method implementing the reaction to a
SetRightRequest
notification requesting rights to be set for a user. |
static void |
AdminTopic.setRightAndSave(SetRight request,
AgentId replyTo,
String msgId)
Deprecated.
|
private void |
ClusterQueue.storeMsgIdInVisitTable(String msgId,
AgentId destId) |
protected void |
Topic.subscribeRequest(AgentId from,
SubscribeRequest not)
Method implementing the reaction to a
SubscribeRequest
instance. |
protected void |
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. |
Constructor and Description |
---|
DestinationDesc(AgentId id,
String name,
byte type) |
QueueDelivery(AgentId consumerId,
int contextId,
Message message) |
Modifier and Type | Field and Description |
---|---|
protected AgentId |
JMSBridgeModule.agentId
Deprecated.
Identifier of the agent using this module.
|
Modifier and Type | Method and Description |
---|---|
private void |
JMSBridgeQueue.bridgeDelivery(AgentId from,
JMSBridgeDeliveryNot not)
Deprecated.
Reacts to
BridgeDeliveryNot notifications holding a message
received from the foreign JMS server. |
private void |
JMSBridgeTopic.bridgeDeliveryNot(AgentId from,
JMSBridgeDeliveryNot not)
Deprecated.
Reacts to
BridgeDeliveryNot notifications holding a message
received from the foreign JMS server. |
void |
JMSBridgeModule.init(AgentId agentId)
Deprecated.
Initializes the module's parameters.
|
ClientMessages |
JMSBridgeTopic.preProcess(AgentId from,
ClientMessages not)
Deprecated.
Method specializing the reaction to a
ClientMessages
instance. |
ClientMessages |
JMSBridgeQueue.preProcess(AgentId from,
ClientMessages not)
Deprecated.
Method specializing the processing of a
ClientMessages
instance. |
void |
JMSBridgeTopic.react(AgentId from,
Notification not)
Deprecated.
Specializes this
Topic method for processing the
specific bridge notifications. |
void |
JMSBridgeQueue.react(AgentId from,
Notification not)
Deprecated.
Specializes this
Queue method for processing the
specific bridge notifications. |
void |
JMSBridgeQueue.receiveRequest(AgentId from,
ReceiveRequest not)
Deprecated.
Method specializing the reaction to a
ReceiveRequest
instance, requesting a message. |
void |
JMSBridgeTopic.topicForwardNot(AgentId from,
TopicForwardNot not)
Deprecated.
Method specializing the reaction to a
TopicForwardNot
instance, carrying messages forwarded by a cluster fellow or a
hierarchical son. |
Modifier and Type | Field and Description |
---|---|
private AgentId |
ClientMessages.proxyId |
private AgentId |
FwdAdminRequestNot.replyTo
The JMS destination to send the reply
|
private AgentId |
ClusterJoinNot.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.
|
AgentId |
TopicDeliveryTimeNot.topic |
Modifier and Type | Method and Description |
---|---|
AgentId |
ClientMessages.getDMQId()
Returns the identifier of the producer's dead message queue, if any.
|
AgentId[] |
GetProxyIdListNot.getIds() |
AgentId |
GetProxyIdNot.getProxyId() |
AgentId |
ClientMessages.getProxyId() |
AgentId |
FwdAdminRequestNot.getReplyTo()
Returns the JMS destination to send the reply.
|
AgentId |
ClusterJoinNot.getReplyTo()
Returns the JMS destination to send the reply.
|
Modifier and Type | Method and Description |
---|---|
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.
|
void |
ClientMessages.setProxyId(AgentId proxyId) |
Constructor and Description |
---|
ClusterJoinNot(Set cluster,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
FwdAdminRequestNot(AdminRequest request,
AgentId replyTo,
String requestMsgId)
Creates a new
FwdAdminRequestNot to send to a remote AdminTopic. |
FwdAdminRequestNot(AdminRequest request,
AgentId replyTo,
String requestMsgId,
String replyMsgId)
Creates a new
FwdAdminRequestNot to send to an administered
target (user or destination). |
TopicDeliveryTimeNot(Message msg,
AgentId topic,
String subName) |
Modifier and Type | Field and Description |
---|---|
private AgentId |
UserAgent.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.
|
(package private) AgentId |
CCUID.ua |
private AgentId |
UserAgent.HeartBeatTask.userId |
Modifier and Type | Field and Description |
---|---|
private Hashtable<AgentId,AgentId> |
ClientContext.deliveringQueues
Identifiers of queues delivering messages.
|
private Hashtable<AgentId,AgentId> |
ClientContext.deliveringQueues
Identifiers of queues delivering messages.
|
private Vector<AgentId> |
ClientContext.tempDestinations
Vector of temporary destinations.
|
private Map<AgentId,TopicSubscription> |
UserAgent.topicsTable
Table holding the
TopicSubscription instances. |
Modifier and Type | Method and Description |
---|---|
AgentId |
ProxyAgentItf.getId()
Returns the proxy's
AgentId identifier. |
AgentId |
ClientSubscription.getProxyId() |
AgentId |
ClientContext.getProxyId() |
AgentId |
AdminNotification.getProxyId()
Returns the
AgentId of the proxy. |
AgentId |
ClientSubscription.getTopicId()
Returns the identifier of the subscription topic.
|
Modifier and Type | Method and Description |
---|---|
(package private) Iterator<AgentId> |
ClientContext.getDeliveringQueues()
Returns the identifiers of the delivering queues.
|
(package private) Map<AgentId,AgentId> |
ClientContext.getDeliveringQueueTable() |
(package private) Map<AgentId,AgentId> |
ClientContext.getDeliveringQueueTable() |
(package private) List<AgentId> |
ClientContext.getTempDestinationList() |
(package private) Iterator<AgentId> |
ClientContext.getTempDestinations() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
ClientContext.addDeliveringQueue(AgentId queueId)
Adds, if not already, the identifier of a delivering queue.
|
(package private) void |
ClientContext.addTemporaryDestination(AgentId destId)
Adds a temporary destination identifier.
|
private void |
UserAgent.deleteTemporaryDestination(AgentId destId) |
private void |
UserAgent.doFwd(AgentId from,
AbstractReplyNot rep)
Distributes the JMS replies to the appropriate reactions.
|
private void |
UserAgent.doFwd(AgentId from,
QueueMsgReply rep)
Actually forwards a
QueueMsgReply coming from a destination
as a ConsumerMessages destinated to the requesting client. |
private void |
UserAgent.doFwd(AgentId from,
TopicMsgsReply rep)
Method implementing the proxy reaction to a
TopicMsgsReply
holding messages published by a topic. |
private void |
UserAgent.doReact(AdminCommandRequest request,
AgentId replyTo,
String requestMsgId) |
private void |
UserAgent.doReact(AgentId from,
ExceptionReply rep)
Actually forwards an
ExceptionReply coming from a destination
as a MomExceptionReply destinated to the requesting client. |
private void |
UserAgent.doReact(AgentId from,
GetClientSubscriptions not)
Used to get number of local subscribers to 'from'.
|
private void |
UserAgent.doReact(AgentId from,
ReconnectSubscribersNot not)
Sends reconnection messages to one or more subscribers.
|
private void |
UserAgent.doReact(ClearSubscription request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
private void |
UserAgent.doReact(DeleteSubscriptionMessage request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
private void |
UserAgent.doReact(GetSubscription request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
private void |
UserAgent.doReact(GetSubscriptionMessage request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
private void |
UserAgent.doReact(GetSubscriptionMessageIds request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
private void |
UserAgent.doReact(GetSubscriptions request,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
static MultiCnxSync |
ConnectionManager.getMultiCnxSync(AgentId proxyId) |
static String |
ClientSubscription.getTransactionPrefix(AgentId proxyId) |
static String |
ClientContext.getTransactionPrefix(AgentId proxyId) |
static boolean |
UserAgent.isValidCC(AgentId ua,
int ctxid) |
void |
UserAgent.react(AgentId from,
Notification not)
Overrides the
Agent class react method for
providing the JMS client proxy with its specific behaviour. |
(package private) void |
ClientSubscription.reactivate(int contextId,
int reqId,
AgentId topicId,
String selector,
boolean noLocal)
Reactivates the subscription.
|
(package private) void |
ClientContext.removeTemporaryDestination(AgentId destId)
Removes a temporary destination identifier.
|
private void |
UserAgent.replyToTopic(AdminReply reply,
AgentId replyTo,
String requestMsgId,
String replyMsgId) |
void |
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,
Object msg,
ConnectionContext ctx) |
(package private) void |
ClientSubscription.setDMQId(AgentId dmqId)
Sets the subscription's dead message queue identifier.
|
void |
ClientSubscription.setProxyId(AgentId proxyId) |
void |
ClientContext.setProxyId(AgentId proxyId) |
private boolean |
UserAgent.updateSubscriptionToTopic(AgentId topicId,
int contextId,
int requestId)
Updates the proxy's subscription to a topic.
|
private boolean |
UserAgent.updateSubscriptionToTopic(AgentId topicId,
int contextId,
int requestId,
boolean asyncSub)
Updates the proxy's subscription to a topic.
|
Constructor and Description |
---|
AdminNotification(AgentId proxyId,
Identity identity)
Constructs an
AdminNotification instance. |
CCUID(AgentId ua,
int ctxid) |
ClientContext(AgentId proxyId,
int id)
Constructs a
ClientContext instance. |
ClientSubscription(AgentId proxyId,
int contextId,
int reqId,
boolean durable,
AgentId topicId,
String name,
String selector,
boolean noLocal,
AgentId dmqId,
int threshold,
int nbMaxMsg,
MessageTable messagesTable,
String clientID)
Constructs a
ClientSubscription instance. |
HeartBeatTask(int timeout,
Integer key,
AgentId userId) |
MultiCnxSync(AgentId pid) |
Modifier and Type | Field and Description |
---|---|
private AgentId |
TcpReader.proxyId |
private AgentId |
TcpConnection.proxyId |
Modifier and Type | Method and Description |
---|---|
AgentId |
TcpConnection.getProxyId() |
Modifier and Type | Method and Description |
---|---|
(package private) TcpConnection |
TcpProxyService.getConnection(AgentId proxyId,
int key) |
Constructor and Description |
---|
TcpConnection(IOControl ioctrl,
ReliableConnectionContext ctx,
AgentId proxyId,
TcpProxyService proxyService,
Identity identity)
Creates a new TCP connection.
|
TcpReader(IOControl ioctrl,
AgentId proxyId,
TcpConnection tcpConnection,
boolean closeConnection,
ConnectionContext ctx)
Creates a new reader.
|
Modifier and Type | Field and Description |
---|---|
private AgentId |
DMQManager.destDmqId |
private AgentId |
TopicDeliveryTimeTask.destId |
private AgentId |
QueueDeliveryTimeTask.destId |
private AgentId |
DMQManager.senderId |
private AgentId |
TopicDeliveryTimeTask.topic |
Modifier and Type | Method and Description |
---|---|
static AgentId |
JoramHelper.createDestination(String destName,
AgentId adminId,
String destClassName,
byte type,
Properties properties,
boolean freerw)
Instantiating the destination class or retrieving the destination.
|
static AgentId |
JoramHelper.createDestination(String destName,
AgentId adminId,
String destClassName,
byte type,
Properties properties,
boolean freeReading,
boolean freeWriting)
Instantiating the destination class or retrieving the destination.
|
Modifier and Type | Method and Description |
---|---|
static AgentId |
JoramHelper.createDestination(String destName,
AgentId adminId,
String destClassName,
byte type,
Properties properties,
boolean freerw)
Instantiating the destination class or retrieving the destination.
|
static AgentId |
JoramHelper.createDestination(String destName,
AgentId adminId,
String destClassName,
byte type,
Properties properties,
boolean freeReading,
boolean freeWriting)
Instantiating the destination class or retrieving the destination.
|
void |
SynchronousAgent.react(AgentId from,
Notification not) |
Constructor and Description |
---|
DMQManager(AgentId currentDestDmq,
AgentId senderId)
Creates a DMQManager.
|
DMQManager(AgentId specificDmq,
AgentId currentDestDmq,
AgentId senderId)
Creates a DMQManager.
|
QueueDeliveryTimeTask(AgentId destId,
Message msg,
boolean throwsExceptionOnFullDest) |
TopicDeliveryTimeTask(AgentId destId,
AgentId topic,
String subName,
Message msg) |
Modifier and Type | Field and Description |
---|---|
private AgentId |
LocalRequestChannel.proxyId |
Modifier and Type | Method and Description |
---|---|
static AgentId |
AMQPAgent.getAMQPId(short serverId)
get destination AgentId of AMQPAgent.
|
Modifier and Type | Method and Description |
---|---|
static void |
StubAgentIn.processRequest(AgentId from,
long keyLock,
long proxyId,
Object request) |
static void |
StubAgentIn.processResponse(AgentId from,
long keyLock,
Object response) |
static void |
AMQPAgent.putResponse(AgentId from,
long lock,
Object response) |
void |
AMQPAgent.react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions.
|
Copyright © 2023 ScalAgent D.T.. All rights reserved.