|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jlab.coda.cMsg.cMsgSubdomainAdapter
org.jlab.coda.cMsg.subdomains.CA
public class CA
cMsg subdomain handler for channel access (CA) subdomain. WARNING: This class may need some thread-safety measures added (Timmer). Executes send/get as CA put/get command. Uses JCA+CAJ.
Constructor Summary | |
---|---|
CA()
|
Method Summary | |
---|---|
void |
handleClientShutdown()
Method to handle a client shutdown. |
void |
handleSendRequest(cMsgMessageFull msg)
Method to handle message sent by client. |
void |
handleSubscribeAndGetRequest(java.lang.String subject,
java.lang.String type,
int id)
Method to synchronously get a single message from the server for a one-time subscription of a subject and type. |
void |
handleSubscribeRequest(java.lang.String subject,
java.lang.String type,
int receiverSubscribeId)
Method to handle subscribe request sent by domain client. |
int |
handleSyncSendRequest(cMsgMessageFull msg)
Method to handle message sent by domain client in synchronous mode. |
void |
handleUnsubscribeRequest(java.lang.String subject,
java.lang.String type,
int receiverSubscribeId)
Method to handle sunsubscribe request sent by domain client. |
boolean |
hasSend()
Method to tell if the "send" cMsg API function is implemented by this interface implementation in the handleSendRequest(org.jlab.coda.cMsg.cMsgMessageFull)
method. |
boolean |
hasSubscribe()
Method to tell if the "subscribe" cMsg API function is implemented by this interface implementation in the handleSubscribeRequest(java.lang.String, java.lang.String, int)
method. |
boolean |
hasSubscribeAndGet()
Method to tell if the "subscribeAndGet" cMsg API function is implemented by this interface implementation in the handleSubscribeAndGetRequest(java.lang.String, java.lang.String, int)
method. |
boolean |
hasSyncSend()
Method to tell if the "syncSend" cMsg API function is implemented by this interface implementation in the handleSyncSendRequest(org.jlab.coda.cMsg.cMsgMessageFull)
method. |
boolean |
hasUnsubscribe()
Method to tell if the "unsubscribe" cMsg API function is implemented by this interface implementation in the handleUnsubscribeRequest(java.lang.String, java.lang.String, int)
method. |
void |
registerClient(cMsgClientInfo info)
Method to register domain client. |
void |
setMessageDeliverer(cMsgDeliverMessageInterface deliverer)
Method to give the subdomain handler on object able to deliver messages to the client. |
void |
setUDLRemainder(java.lang.String UDLRemainder)
Method to give the subdomain handler the appropriate part of the UDL the client used to talk to the domain server. |
Methods inherited from class org.jlab.coda.cMsg.cMsgSubdomainAdapter |
---|
handleKeepAlive, handleSendAndGetRequest, handleShutdownClientsRequest, handleUnSendAndGetRequest, handleUnsubscribeAndGetRequest, hasSendAndGet, hasShutdown |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CA()
Method Detail |
---|
public boolean hasSend()
handleSendRequest(org.jlab.coda.cMsg.cMsgMessageFull)
method.
hasSend
in interface cMsgSubdomainInterface
hasSend
in class cMsgSubdomainAdapter
handleSendRequest(org.jlab.coda.cMsg.cMsgMessageFull)
public boolean hasSyncSend()
handleSyncSendRequest(org.jlab.coda.cMsg.cMsgMessageFull)
method.
hasSyncSend
in interface cMsgSubdomainInterface
hasSyncSend
in class cMsgSubdomainAdapter
handleSyncSendRequest(org.jlab.coda.cMsg.cMsgMessageFull)
public boolean hasSubscribeAndGet()
handleSubscribeAndGetRequest(java.lang.String, java.lang.String, int)
method.
hasSubscribeAndGet
in interface cMsgSubdomainInterface
hasSubscribeAndGet
in class cMsgSubdomainAdapter
handleSubscribeAndGetRequest(java.lang.String, java.lang.String, int)
public boolean hasSubscribe()
handleSubscribeRequest(java.lang.String, java.lang.String, int)
method.
hasSubscribe
in interface cMsgSubdomainInterface
hasSubscribe
in class cMsgSubdomainAdapter
handleSubscribeRequest(java.lang.String, java.lang.String, int)
public boolean hasUnsubscribe()
handleUnsubscribeRequest(java.lang.String, java.lang.String, int)
method.
hasUnsubscribe
in interface cMsgSubdomainInterface
hasUnsubscribe
in class cMsgSubdomainAdapter
handleUnsubscribeRequest(java.lang.String, java.lang.String, int)
public void setUDLRemainder(java.lang.String UDLRemainder) throws cMsgException
setUDLRemainder
in interface cMsgSubdomainInterface
setUDLRemainder
in class cMsgSubdomainAdapter
UDLRemainder
- last part of the UDL appropriate to the subdomain handler
cMsgException
public void setMessageDeliverer(cMsgDeliverMessageInterface deliverer) throws cMsgException
setMessageDeliverer
in interface cMsgSubdomainInterface
setMessageDeliverer
in class cMsgSubdomainAdapter
deliverer
- object able to deliver messages to the client
cMsgException
public void registerClient(cMsgClientInfo info) throws cMsgException
registerClient
in interface cMsgSubdomainInterface
registerClient
in class cMsgSubdomainAdapter
info
- information about client
cMsgException
- if unable to registerpublic void handleSendRequest(cMsgMessageFull msg) throws cMsgException
handleSendRequest
in interface cMsgSubdomainInterface
handleSendRequest
in class cMsgSubdomainAdapter
msg
- message from sender
cMsgException
- if a channel to the client is closed, cannot be created,
or socket properties cannot be setpublic int handleSyncSendRequest(cMsgMessageFull msg) throws cMsgException
handleSyncSendRequest
in interface cMsgSubdomainInterface
handleSyncSendRequest
in class cMsgSubdomainAdapter
msg
- message from sender
cMsgException
public void handleSubscribeAndGetRequest(java.lang.String subject, java.lang.String type, int id) throws cMsgException
handleSubscribeAndGetRequest
in interface cMsgSubdomainInterface
handleSubscribeAndGetRequest
in class cMsgSubdomainAdapter
subject
- message subject subscribed totype
- message type subscribed toid
- message id refering to these specific subject and type values
cMsgException
public void handleSubscribeRequest(java.lang.String subject, java.lang.String type, int receiverSubscribeId) throws cMsgException
handleSubscribeRequest
in interface cMsgSubdomainInterface
handleSubscribeRequest
in class cMsgSubdomainAdapter
subject
- message subject to subscribe totype
- message type to subscribe toreceiverSubscribeId
- message id refering to these specific subject and type values
cMsgException
- if no client information is available or a subscription for this
subject and type already existspublic void handleUnsubscribeRequest(java.lang.String subject, java.lang.String type, int receiverSubscribeId) throws cMsgException
handleUnsubscribeRequest
in interface cMsgSubdomainInterface
handleUnsubscribeRequest
in class cMsgSubdomainAdapter
subject
- message subject subscribed totype
- message type subscribed toreceiverSubscribeId
- message id refering to these specific subject and type values
cMsgException
public void handleClientShutdown() throws cMsgException
handleClientShutdown
in interface cMsgSubdomainInterface
handleClientShutdown
in class cMsgSubdomainAdapter
cMsgException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |