org.jlab.coda.cMsg.cMsgDomain.server

Class cMsgServerBridge.SendAndGetCallback

java.lang.Object

org.jlab.coda.cMsg.cMsgCallbackAdapter

org.jlab.coda.cMsg.cMsgDomain.server.cMsgServerBridge.SendAndGetCallback

All Implemented Interfaces:

cMsgCallbackInterface

Enclosing class:

cMsgServerBridge

static class cMsgServerBridge.SendAndGetCallback
extends cMsgCallbackAdapter

This class defines the callback to be run when a sendAndGet response message arrives from a bridge connection and must be passed on to a client(s).

Field Summary

Fields

Modifier and Type	Field and Description
(package private) int	id Send messges's senderToken on this server.
(package private) java.util.concurrent.atomic.AtomicBoolean	skip Allow this callback to skip extra incoming messages since only one is needed.
(package private) int	sysMsgId Send message's sysMsgId on this server.

Constructor Summary

Constructors

Constructor and Description
SendAndGetCallback(int id, int sysMsgId) Constructor.

Method Summary

Modifier and Type	Method and Description
void	callback(cMsgMessage msg, java.lang.Object userObject) Callback which passes on a message to local clients.

Methods inherited from class org.jlab.coda.cMsg.cMsgCallbackAdapter

getMaximumQueueSize, getMaximumThreads, getMessagesPerThread, getSkipSize, maySkipMessages, mustSerializeMessages

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

id

int id

Send messges's senderToken on this server.

sysMsgId

int sysMsgId

Send message's sysMsgId on this server.

skip

java.util.concurrent.atomic.AtomicBoolean skip

Allow this callback to skip extra incoming messages since only one is needed.

Constructor Detail

SendAndGetCallback

SendAndGetCallback(int id,
                   int sysMsgId)

Constructor.

Parameters:

id - incoming message's senderToken needs to be changed to this value

sysMsgId - incoming message's sysMsgId needs to be changed to this value

Method Detail

callback

public void callback(cMsgMessage msg,
                     java.lang.Object userObject)

Callback which passes on a message to local clients.

Specified by:

callback in interface cMsgCallbackInterface

Overrides:

callback in class cMsgCallbackAdapter

Parameters:

msg - message received from domain server

userObject - in this case the original msg sender's namespace.