org.jlab.coda.cMsg.cMsgDomain.server

Class cMsgServerBridge.SubscribeCallback

java.lang.Object

org.jlab.coda.cMsg.cMsgCallbackAdapter

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

All Implemented Interfaces:

cMsgCallbackInterface

Enclosing class:

cMsgServerBridge

static class cMsgServerBridge.SubscribeCallback
extends cMsgCallbackAdapter

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

Constructor Summary

Constructors

Constructor and Description
SubscribeCallback()

Method Summary

Modifier and Type	Method and Description
void	callback(cMsgMessage msg, java.lang.Object userObject) Callback which passes on a message to other clients.
int	getMaximumQueueSize() Method to get the maximum number of messages to queue for the callback.

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

getMaximumThreads, getMessagesPerThread, getSkipSize, maySkipMessages, mustSerializeMessages

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscribeCallback

SubscribeCallback()

Method Detail

callback

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

Callback which passes on a message to other 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.

getMaximumQueueSize

public int getMaximumQueueSize()

Description copied from class: cMsgCallbackAdapter

Method to get the maximum number of messages to queue for the callback.

Specified by:

getMaximumQueueSize in interface cMsgCallbackInterface

Overrides:

getMaximumQueueSize in class cMsgCallbackAdapter

Returns:

maximum number of messages to queue for the callback