org.jlab.coda.cMsg.cMsgDomain.server

Class cMsgServerSubscribeAndGetter

java.lang.Object

org.jlab.coda.cMsg.cMsgDomain.server.cMsgServerSubscribeAndGetter

All Implemented Interfaces:

java.lang.Runnable

class cMsgServerSubscribeAndGetter
extends java.lang.Object
implements java.lang.Runnable

This class handles a server client's subscribeAndGet request and propagates it to all the connected servers. It takes care of all the details of getting a response and forwarding that to the client as well as cancelling the request to servers after the first response is received.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) cMsgCallbackAdapter	cb Callback for this subscription.
(package private) cMsgNotifier	notifier Wait on this object which tells us when a matching message has been sent to a subscribeAndGet so we can notify bridges to cancel their subscriptions (which are used to implement remote subAndGets).
(package private) cMsgServerSubscribeInfo	sub Contains information about this particular subscription.
(package private) java.util.Set<cMsgServerSubscribeInfo>	subscriptions Contains all subscriptions made by this server.

Constructor Summary

Constructors

Constructor and Description
cMsgServerSubscribeAndGetter(cMsgNameServer nameServer, cMsgNotifier notifier, cMsgCallbackAdapter cb, java.util.Set<cMsgServerSubscribeInfo> subscriptions, cMsgServerSubscribeInfo sub) Constructor.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

notifier

cMsgNotifier notifier

Wait on this object which tells us when a matching message has been sent to a subscribeAndGet so we can notify bridges to cancel their subscriptions (which are used to implement remote subAndGets).

subscriptions

java.util.Set<cMsgServerSubscribeInfo> subscriptions

Contains all subscriptions made by this server.

sub

cMsgServerSubscribeInfo sub

Contains information about this particular subscription.

cb

cMsgCallbackAdapter cb

Callback for this subscription.

Constructor Detail

cMsgServerSubscribeAndGetter

public cMsgServerSubscribeAndGetter(cMsgNameServer nameServer,
                                    cMsgNotifier notifier,
                                    cMsgCallbackAdapter cb,
                                    java.util.Set<cMsgServerSubscribeInfo> subscriptions,
                                    cMsgServerSubscribeInfo sub)

Constructor.

Parameters:

nameServer - name server

notifier - notifier

cb - callback

subscriptions - set of subscriptions

sub - server client's subscription

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable