Package | Description |
---|---|
com.scalagent.joram.mom.dest.ftp | |
com.scalagent.joram.mom.dest.scheduler | |
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 |
Modifier and Type | Class and Description |
---|---|
class |
FtpNot |
Modifier and Type | Method and Description |
---|---|
ClientMessages |
FtpQueue.preProcess(AgentId from,
ClientMessages not) |
Modifier and Type | Method and Description |
---|---|
private void |
FtpQueue.doProcessFtp(ClientMessages not,
Message msg) |
ClientMessages |
FtpQueue.preProcess(AgentId from,
ClientMessages not) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerQueue.postProcess(ClientMessages not) |
Modifier and Type | Field and Description |
---|---|
private ClientMessages |
AcquisitionNot.acquiredMessages |
Modifier and Type | Method and Description |
---|---|
ClientMessages |
AcquisitionModule.acquisitionNot(AcquisitionNot not,
long msgCount) |
ClientMessages |
AcquisitionNot.getAcquiredMessages() |
protected ClientMessages |
Queue.getClientMessages(int nb,
String selector,
boolean remove)
Get a client message contain
nb messages. |
protected ClientMessages |
ClusterQueue.getClientMessages(int nb,
String selector,
boolean remove)
get a client message contain nb messages.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Queue.addClientMessages(ClientMessages clientMsgs,
boolean throwsExceptionOnFullDest)
Adds the client messages in the queue.
|
protected void |
Destination.clientMessages(AgentId from,
ClientMessages not)
Method implementing the reaction to a
ClientMessages
notification holding messages sent by a client. |
protected TopicForwardNot |
Topic.createTopicForward(AgentId destId,
ClientMessages messages,
boolean fromCluster) |
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)
Forward incoming publications to all fathers.
|
protected abstract void |
Destination.doClientMessages(AgentId from,
ClientMessages not,
boolean throwsExceptionOnFullDest) |
private void |
Topic.doClientMessages(AgentId from,
ClientMessages not,
boolean fromCluster,
boolean throwsExceptionOnFullDest) |
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) |
protected void |
DistributionTopic.postProcess(ClientMessages msgs) |
protected void |
DistributionQueue.postProcess(ClientMessages cm) |
protected void |
Destination.postProcess(ClientMessages msgs)
This method is needed to add processing after the standard handling.
|
void |
ClusterQueue.postProcess(ClientMessages not)
call factorCheck to evaluate the loading factor,
activity, ... and send message to cluster if need.
|
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.
|
private void |
AdminTopic.processAdminRequests(ClientMessages not)
Method getting the administration requests from messages, and
distributing them to the appropriate reactions.
|
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. |
void |
AcquisitionModule.processMessages(ClientMessages cm)
In request mode (period <= 0), a message received on the acquisition
destination will launch an acquisition process.
|
Constructor and Description |
---|
AcquisitionNot(ClientMessages acquiredMessages,
boolean persistent,
String id) |
Modifier and Type | Method and Description |
---|---|
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. |
Modifier and Type | Method and Description |
---|---|
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. |
Modifier and Type | Field and Description |
---|---|
private ClientMessages |
LBMessageGive.clientMessages |
private ClientMessages |
LBCycleLife.clientMessages |
ClientMessages |
TopicForwardNot.messages
The forwarded messages.
|
Modifier and Type | Method and Description |
---|---|
ClientMessages |
LBMessageGive.getClientMessages() |
ClientMessages |
LBCycleLife.getClientMessages() |
Modifier and Type | Method and Description |
---|---|
void |
RequestGroupNot.addClientMessages(ClientMessages cm) |
void |
LBMessageGive.setClientMessages(ClientMessages clientMessages) |
void |
LBCycleLife.setClientMessages(ClientMessages clientMessages) |
Constructor and Description |
---|
TopicForwardNot(ClientMessages messages,
boolean fromCluster)
Constructs a
TopicForwardNot instance. |
Modifier and Type | Method and Description |
---|---|
private void |
UserAgent.setDmq(ClientMessages not) |
Modifier and Type | Field and Description |
---|---|
private ClientMessages |
DMQManager.deadMessages |
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.