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.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.util | |
org.ow2.joram.mom.amqp |
Modifier and Type | Class and Description |
---|---|
class |
FtpNot |
Modifier and Type | Method and Description |
---|---|
void |
FtpQueue.react(AgentId from,
Notification not) |
Modifier and Type | Class and Description |
---|---|
class |
SchedulerQueueNot
Notification from Scheduler to SchedulerQueue.
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulerQueue.react(AgentId from,
Notification not) |
Modifier and Type | Class and Description |
---|---|
class |
AgentCreateReply |
class |
AgentCreateRequest
This notification is used to ask aa agent creation to a remote
agent factory.
|
class |
AgentDeleteRequest |
class |
CallbackNotification
Notification locally transmitting a
CountDownCallback . |
class |
DeleteAck
DeleteAck - Acknowledge for deleting an agent
|
class |
DeleteNot
This notification is used to ask an agent destruction
|
class |
ExceptionNotification
Notify by the engine to the sender of a notification when the corresponding
reaction throws an exception.
|
class |
ExpiredNot
The ExpiredNot holds an expired notification (timeout) which is sent to the
previously specified deadNotificationAgent.
|
class |
FlowControlNot
Flow control notification.
|
class |
SyncNotification
This notification is used to synchronously call a
local agent from a collocated thread.
|
class |
UnknownAgent
Notify by the engine to the sender of a notification when the target agent
does not exist.
|
class |
UnknownNotification
Notify by agents when there is no reaction allowed.
|
Modifier and Type | Field and Description |
---|---|
private Notification |
ExpiredNot.expiredNot
The expiration which had expired.
|
Notification |
UnknownNotification.not
The failing notification.
|
Notification |
UnknownAgent.not
The failing notification that can not be delivered.
|
(package private) Notification |
Message.not
The notification.
|
Notification |
ExceptionNotification.not
The failing notification.
|
private Notification |
SyncNotification.Context.syncRequest |
Modifier and Type | Method and Description |
---|---|
Notification |
ExpiredNot.getExpiredNot() |
Notification |
Message.getNot() |
Modifier and Type | Method and Description |
---|---|
(package private) static Message |
Message.alloc(AgentId from,
AgentId to,
Notification not)
Allocates a message from the pool.
|
Message |
AgentEngineContextImpl.createMessage(AgentId from,
AgentId to,
Notification not)
Creates a message.
|
Message |
AgentEngineContext.createMessage(AgentId from,
AgentId to,
Notification not)
Creates a message.
|
private void |
MessageVector.dec(Notification not) |
(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.
|
private void |
MessageVector.inc(Notification not) |
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.
|
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.
|
protected void |
Agent.sendTo(RoleMultiple role,
Notification not)
Sends a notification to all the agents registered in a role.
|
protected void |
Agent.sendTo(Role role,
Notification not)
This method sends a notification to the agent which id is wrapped
in the specified role.
|
private void |
Message.set(AgentId from,
AgentId to,
Notification not) |
Constructor and Description |
---|
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.
|
SyncNotification.Context(Notification syncRequest) |
UnknownAgent(AgentId agent,
Notification not)
Allocates a new
UnknownAgent notification. |
UnknownNotification(AgentId agent,
Notification not)
Allocates a new
UnknownNotification notification. |
Modifier and Type | Class and Description |
---|---|
class |
InitJndiServerNot |
class |
JndiUpdateNot |
class |
SyncReplyNot |
class |
SyncRequestNot |
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicationEntryPoint.accept(AgentId from,
Notification not) |
Modifier and Type | Class and Description |
---|---|
class |
JndiReplyNot |
class |
JndiScriptReplyNot |
class |
JndiScriptRequestNot |
class |
TcpRequestNot
This notification must only be used inside an agent server.
|
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) |
void |
Container.react(AgentId from,
Notification not) |
(package private) void |
Container.sendNotification(AgentId to,
Notification not) |
void |
RequestManager.sendTo(AgentId to,
Notification not) |
Modifier and Type | Class and Description |
---|---|
class |
AcquisitionNot |
Modifier and Type | Method and Description |
---|---|
protected void |
Destination.forward(AgentId to,
Notification not) |
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) |
private void |
AliasInQueue.sendNot(Notification not) |
protected void |
Topic.sendToCluster(Notification not)
Sends a notification to all topics in cluster.
|
protected void |
ClusterQueue.sendToCluster(Notification not)
Sends a notification to all queue in cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
JMSBridgeAckNot
Deprecated.
|
class |
JMSBridgeDeliveryNot
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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. |
Modifier and Type | Class and Description |
---|---|
class |
AbortReceiveRequest |
class |
AbstractNotification
The
AbstractNotification class is the superclass of the
notifications exchanged by a client agent and a MOM destination agent. |
class |
AbstractReplyNot
An
AbstractReply is a reply sent by a destination agent to
a client agent. |
class |
AbstractRequestNot
An
AbstractRequest is a request sent by a client agent to
a destination agent. |
class |
AcknowledgeRequest
An
AcknowledgeRequest instance is used by a client agent
for acknowledging one or many messages on a queue. |
class |
AdminReplyNot
An
AdminReply is used by a destination agent for replying to
a client administration request. |
class |
AdminRequestNot
An
AdminRequest is used by a client agent for sending an
administration request to a destination agent. |
class |
BrowseReply
A
BrowseReply instance is used by a queue for replying
to a client BrowseRequest by sending a vector of its messages. |
class |
BrowseRequest
A
BrowseRequest instance is used by a client agent for
requesting a "view" of the messages on a queue, without actually consuming
them. |
class |
ClientMessages
A
ClientMessages instance is used by a client agent for
sending one or many messages to a destination. |
class |
ClientSubscriptionNot
Used by ElasticTopic.
|
class |
ClusterJoinAck |
class |
ClusterJoinNot |
class |
ClusterLBNot |
class |
ClusterRemoveNot |
class |
DenyRequest
A
DenyRequest instance is used by a client agent
for denying one or many messages on a queue. |
class |
ExceptionReply
An
ExceptionReply instance is used by a destination for
notifying a client of an exception thrown when processing a request. |
class |
FwdAdminRequestNot
An
AdminRequest is used by a client agent for sending an
administration request to a destination agent. |
class |
GetClientSubscriptions
Used by ElasticTopic.
|
class |
GetProxyIdListNot
Transient notification needed by the HA mode.
|
class |
GetProxyIdNot
Transient notification
|
class |
GetRightsReplyNot
This notification is used by a destination for sending the identifiers of its readers
and writers in response to a GetRightsRequest.
|
class |
GetRightsRequestNot
This request is used for requesting the rights about a destination.
|
class |
LBCycleLife |
class |
LBLoadingFactor |
class |
LBMessageGive |
class |
LBMessageHope |
class |
PingNot
An empty notification, sent to a destination to test whether it is currently
accessible.
|
class |
PongNot
A notification sent in response of a
PingNot . |
class |
QueueDeliveryTimeNot |
class |
QueueMsgReply
A
QueueMsgReply instance is used by a queue for replying to a
ReceiveRequest by sending a message to a client. |
class |
ReceiveRequest
A
ReceiveRequest instance is used by a client agent for
requesting a message on a queue. |
class |
ReconnectSubscribersNot
Used by ElasticTopic
|
class |
RequestGroupNot |
class |
SubscribeReply
A
SubscribeReply instance is used by a topic agent
for acknowledging a SubscribeRequest notification. |
class |
SubscribeRequest
A
SubscribeRequest instance is used by a client agent
for subscribing to a topic. |
class |
TopicDeliveryTimeNot |
class |
TopicForwardNot
A
TopicForwardNot is a notification sent by a topic to
another topic part of the same cluster, or to its hierarchical father,
and holding a forwarded ClientMessages notification. |
class |
TopicMsgsReply
A
TopicMsgsReply instance is used by a topic for sending
messages to an agent client which subscribed to it. |
class |
UnsubscribeRequest
An
UnsubscribeRequest instance is used by a client agent
for unsubscribing to a topic. |
class |
WakeUpNot |
Modifier and Type | Class and Description |
---|---|
class |
AdminNotification
An
AdminNotification is sent during initialization by an
administrator's proxy for registering to the local administration topic. |
class |
CloseConnectionNot |
class |
CloseConnectionNot2 |
class |
GetConnectionNot |
class |
OpenConnectionNot |
class |
ProxyRequestGroupNot |
class |
RequestNot |
class |
ResetCollocatedConnectionsNot |
class |
ReturnConnectionNot |
class |
SendRepliesNot |
class |
SendReplyNot |
(package private) class |
SyncReply
A
SyncReply is a notification used by a proxy for
synchronizing a reply. |
Modifier and Type | Method and Description |
---|---|
void |
UserAgent.react(AgentId from,
Notification not)
Overrides the
Agent class react method for
providing the JMS client proxy with its specific behaviour. |
void |
UserAgent.sendNot(AgentId to,
Notification not)
Sends a notification to the specified agent.
|
void |
ProxyAgentItf.sendNot(AgentId to,
Notification not)
Sends a notification to a given agent.
|
Modifier and Type | Method and Description |
---|---|
void |
SynchronousAgent.react(AgentId from,
Notification not) |
Modifier and Type | Class and Description |
---|---|
class |
AMQPRequestNot
Notification used to make a request to another Joram AMQP server.
|
class |
AMQPResponseNot
Notification used to answer a request coming from another Joram AMQP server.
|
class |
RestartNot
Notification used to tell other Joram AMQP servers that a server has
restarted.
|
Modifier and Type | Method and Description |
---|---|
void |
AMQPAgent.react(AgentId from,
Notification not)
Distributes the received notifications to the appropriate reactions.
|
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.