Uses of Class
org.objectweb.joram.mom.notifications.ClientMessages
-
Packages that use ClientMessages Package Description com.scalagent.joram.mom.dest.ftp com.scalagent.joram.mom.dest.scheduler org.objectweb.joram.mom.dest Theorg.objectweb.joram.mom.destpackage holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM.org.objectweb.joram.mom.notifications Theorg.objectweb.joram.mom.notificationspackage holds the notifications used for interacting with the MOM destination agents.org.objectweb.joram.mom.proxies Theorg.objectweb.joram.mom.proxiespackage holds the classes implementing the MOM proxy, basically linking external client applications to destination agents.org.objectweb.joram.mom.util -
-
Uses of ClientMessages in com.scalagent.joram.mom.dest.ftp
Subclasses of ClientMessages in com.scalagent.joram.mom.dest.ftp Modifier and Type Class Description classFtpNotMethods in com.scalagent.joram.mom.dest.ftp that return ClientMessages Modifier and Type Method Description ClientMessagesFtpQueue. preProcess(AgentId from, ClientMessages not)Methods in com.scalagent.joram.mom.dest.ftp with parameters of type ClientMessages Modifier and Type Method Description private voidFtpQueue. doProcessFtp(ClientMessages not, Message msg)ClientMessagesFtpQueue. 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 Modifier and Type Method Description voidSchedulerQueue. postProcess(ClientMessages not) -
Uses of ClientMessages in org.objectweb.joram.mom.dest
Fields in org.objectweb.joram.mom.dest declared as ClientMessages Modifier and Type Field Description private ClientMessagesAcquisitionNot. acquiredMessagesMethods in org.objectweb.joram.mom.dest that return ClientMessages Modifier and Type Method Description ClientMessagesAcquisitionModule. acquisitionNot(AcquisitionNot not, long msgCount)ClientMessagesAcquisitionNot. getAcquiredMessages()protected ClientMessagesClusterQueue. getClientMessages(int nb, String selector, boolean remove)get a client message contain nb messages.protected ClientMessagesQueue. getClientMessages(int nb, String selector, boolean remove)Get a client message containnbmessages.ClientMessagesAcquisitionQueue. 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.ClientMessagesAcquisitionTopic. 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 ClientMessagesAdminTopic. preProcess(AgentId from, ClientMessages msgs)Overrides thisDestinationmethod;ClientMessagesAliasInQueue. preProcess(AgentId from, ClientMessages cm)ClientMessagesAliasQueue. preProcess(AgentId from, ClientMessages cm)ClientMessagesClusterQueue. preProcess(AgentId from, ClientMessages not)overload preProcess(AgentId, ClientMessages) store all msgId in timeTable and visitTable.protected ClientMessagesDestination. preProcess(AgentId from, ClientMessages msgs)This method is needed to add processing before the standard handling.ClientMessagesDistributionQueue. preProcess(AgentId from, ClientMessages cm)ClientMessagesDistributionTopic. preProcess(AgentId from, ClientMessages cm)Be careful, the message must be completely loaded (body).Methods in org.objectweb.joram.mom.dest with parameters of type ClientMessages Modifier and Type Method Description voidQueue. addClientMessages(ClientMessages clientMsgs, boolean throwsExceptionOnFullDest)Adds the client messages in the queue.protected voidDestination. clientMessages(AgentId from, ClientMessages not)Method implementing the reaction to aClientMessagesnotification holding messages sent by a client.protected TopicForwardNotTopic. createTopicForward(AgentId destId, ClientMessages messages, boolean fromCluster)protected abstract voidDestination. doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)protected voidElasticTopic. doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)protected voidQueue. doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)Method specifically processing aClientMessagesinstance.protected voidTopic. doClientMessages(AgentId from, ClientMessages not, boolean throwsExceptionOnFullDest)Method specifically processing aClientMessagesinstance.private voidTopic. doClientMessages(AgentId from, ClientMessages not, boolean fromCluster, boolean throwsExceptionOnFullDest)protected voidTopic. forwardMessages(AgentId from, ClientMessages messages)Actually forwards a list of messages to the father or the cluster fellows, if any.protected voidTopic. forwardMessages(AgentId from, ClientMessages messages, boolean fromCluster)voidClusterQueue. postProcess(ClientMessages not)call factorCheck to evaluate the loading factor, activity, ... and send message to cluster if need.protected voidDestination. postProcess(ClientMessages msgs)This method is needed to add processing after the standard handling.protected voidDistributionQueue. postProcess(ClientMessages cm)protected voidDistributionTopic. postProcess(ClientMessages msgs)ClientMessagesAcquisitionQueue. 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.ClientMessagesAcquisitionTopic. 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 ClientMessagesAdminTopic. preProcess(AgentId from, ClientMessages msgs)Overrides thisDestinationmethod;ClientMessagesAliasInQueue. preProcess(AgentId from, ClientMessages cm)ClientMessagesAliasQueue. preProcess(AgentId from, ClientMessages cm)ClientMessagesClusterQueue. preProcess(AgentId from, ClientMessages not)overload preProcess(AgentId, ClientMessages) store all msgId in timeTable and visitTable.protected ClientMessagesDestination. preProcess(AgentId from, ClientMessages msgs)This method is needed to add processing before the standard handling.ClientMessagesDistributionQueue. preProcess(AgentId from, ClientMessages cm)ClientMessagesDistributionTopic. preProcess(AgentId from, ClientMessages cm)Be careful, the message must be completely loaded (body).private voidAdminTopic. processAdminRequests(ClientMessages not)Method getting the administration requests from messages, and distributing them to the appropriate reactions.voidAcquisitionModule. processMessages(ClientMessages cm)In request mode (period <= 0), a message received on the acquisition destination will launch an acquisition process.protected voidTopic. processMessages(AgentId from, ClientMessages not)Actually processes the distribution of the received messages to the valid subscriptions by sending aTopicMsgsReplynotification to the valid subscribers.Constructors in org.objectweb.joram.mom.dest with parameters of type ClientMessages Constructor Description AcquisitionNot(ClientMessages acquiredMessages, boolean persistent, String id) -
Uses of ClientMessages in org.objectweb.joram.mom.notifications
Fields in org.objectweb.joram.mom.notifications declared as ClientMessages Modifier and Type Field Description private ClientMessagesLBCycleLife. clientMessagesprivate ClientMessagesLBMessageGive. clientMessagesprivate ClientMessagesTopicForwardNot. messagesThe forwarded messages.Fields in org.objectweb.joram.mom.notifications with type parameters of type ClientMessages Modifier and Type Field Description private Vector<ClientMessages>RequestGroupNot. clientMessagesMethods in org.objectweb.joram.mom.notifications that return ClientMessages Modifier and Type Method Description ClientMessagesLBCycleLife. getClientMessages()ClientMessagesLBMessageGive. getClientMessages()ClientMessagesTopicForwardNot. getMessages()Methods in org.objectweb.joram.mom.notifications that return types with arguments of type ClientMessages Modifier and Type Method Description Enumeration<ClientMessages>RequestGroupNot. getClientMessages()Methods in org.objectweb.joram.mom.notifications with parameters of type ClientMessages Modifier and Type Method Description voidRequestGroupNot. addClientMessages(ClientMessages cm)voidLBCycleLife. setClientMessages(ClientMessages clientMessages)voidLBMessageGive. setClientMessages(ClientMessages clientMessages)Constructors in org.objectweb.joram.mom.notifications with parameters of type ClientMessages Constructor Description TopicForwardNot(ClientMessages messages, boolean fromCluster)Constructs aTopicForwardNotinstance. -
Uses of ClientMessages in org.objectweb.joram.mom.proxies
Methods in org.objectweb.joram.mom.proxies with parameters of type ClientMessages Modifier and Type Method Description private voidUserAgent. setDmq(ClientMessages not) -
Uses of ClientMessages in org.objectweb.joram.mom.util
Fields in org.objectweb.joram.mom.util declared as ClientMessages Modifier and Type Field Description private ClientMessagesDMQManager. deadMessages
-