|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ClientMessages | |
---|---|
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. |
Uses of ClientMessages in com.scalagent.joram.mom.dest.ftp |
---|
Subclasses of ClientMessages in com.scalagent.joram.mom.dest.ftp | |
---|---|
class |
FtpNot
|
Methods in com.scalagent.joram.mom.dest.ftp that return ClientMessages | |
---|---|
ClientMessages |
FtpQueue.preProcess(AgentId from,
ClientMessages not)
|
Methods in com.scalagent.joram.mom.dest.ftp with parameters of type ClientMessages | |
---|---|
ClientMessages |
FtpQueue.preProcess(AgentId from,
ClientMessages not)
|
Uses of ClientMessages in com.scalagent.joram.mom.dest.scheduler |
---|
Methods in com.scalagent.joram.mom.dest.scheduler with parameters of type ClientMessages | |
---|---|
void |
SchedulerQueue.postProcess(ClientMessages not)
|
Uses of ClientMessages in org.objectweb.joram.mom.dest |
---|
Methods in org.objectweb.joram.mom.dest that return ClientMessages | |
---|---|
ClientMessages |
AcquisitionModule.acquisitionNot(AcquisitionNot not,
long msgCount)
|
ClientMessages |
AcquisitionNot.getAcquiredMessages()
|
protected ClientMessages |
Queue.getClientMessages(int nb,
java.lang.String selector,
boolean remove)
Get a client message contain nb messages. |
protected ClientMessages |
ClusterQueue.getClientMessages(int nb,
java.lang.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. |
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. |
ClientMessages |
DistributionModule.processMessages(ClientMessages cm)
Messages received on the distribution destination are distributed using the specified DistributionHandler . |
Methods in org.objectweb.joram.mom.dest with parameters of type ClientMessages | |
---|---|
void |
Queue.addClientMessages(ClientMessages clientMsgs)
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 void |
Topic.doClientMessages(AgentId from,
ClientMessages not)
Method specifically processing a ClientMessages instance. |
protected void |
Queue.doClientMessages(AgentId from,
ClientMessages not)
Method specifically processing a ClientMessages instance. |
protected abstract void |
Destination.doClientMessages(AgentId from,
ClientMessages not)
|
protected void |
Topic.forwardMessages(ClientMessages messages)
Actually forwards a list of messages to the father or the cluster fellows, if any. |
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. |
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 |
Topic.processMessages(ClientMessages not)
Actually processes the distribution of the received messages to the valid subscriptions by sending a TopicMsgsReply notification
to the valid subscribers. |
ClientMessages |
DistributionModule.processMessages(ClientMessages cm)
Messages received on the distribution destination are distributed using the specified DistributionHandler . |
void |
AcquisitionModule.processMessages(ClientMessages cm)
In periodic mode (period > 0), a message with non-null properties transmit properties to the handler. |
Constructors in org.objectweb.joram.mom.dest with parameters of type ClientMessages | |
---|---|
AcquisitionNot(ClientMessages acquiredMessages,
boolean persistent,
java.lang.String id)
|
Uses of ClientMessages in org.objectweb.joram.mom.dest.jmsbridge |
---|
Methods in org.objectweb.joram.mom.dest.jmsbridge that return ClientMessages | |
---|---|
ClientMessages |
JMSBridgeTopic.preProcess(AgentId from,
ClientMessages not)
Method specializing the reaction to a ClientMessages
instance. |
ClientMessages |
JMSBridgeQueue.preProcess(AgentId from,
ClientMessages not)
Method specializing the processing of a ClientMessages
instance. |
Methods in org.objectweb.joram.mom.dest.jmsbridge with parameters of type ClientMessages | |
---|---|
ClientMessages |
JMSBridgeTopic.preProcess(AgentId from,
ClientMessages not)
Method specializing the reaction to a ClientMessages
instance. |
ClientMessages |
JMSBridgeQueue.preProcess(AgentId from,
ClientMessages not)
Method specializing the processing of a ClientMessages
instance. |
Uses of ClientMessages in org.objectweb.joram.mom.notifications |
---|
Fields in org.objectweb.joram.mom.notifications declared as ClientMessages | |
---|---|
ClientMessages |
TopicForwardNot.messages
The forwarded messages. |
Methods in org.objectweb.joram.mom.notifications that return ClientMessages | |
---|---|
ClientMessages |
LBMessageGive.getClientMessages()
|
ClientMessages |
LBCycleLife.getClientMessages()
|
Methods in org.objectweb.joram.mom.notifications with parameters of type ClientMessages | |
---|---|
void |
RequestGroupNot.addClientMessages(ClientMessages cm)
|
void |
LBMessageGive.setClientMessages(ClientMessages clientMessages)
|
void |
LBCycleLife.setClientMessages(ClientMessages clientMessages)
|
Constructors in org.objectweb.joram.mom.notifications with parameters of type ClientMessages | |
---|---|
TopicForwardNot(ClientMessages messages,
boolean fromCluster)
Constructs a TopicForwardNot instance. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |