|
||||||||||
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.FileQueue
public class FileQueue
cMsg subdomain handler for FileQueue subdomain. UDL: cMsg:cMsg://host:port/FileQueue/myQueueName?dir=myDirName. e.g. cMsg:cMsg://ollie/FileQueue/ejw?dir=/home/wolin/qdir. stores/retrieves cMsgMessageFull messages from file-based queue.
Constructor Summary | |
---|---|
FileQueue()
|
Method Summary | |
---|---|
void |
handleSendAndGetRequest(cMsgMessageFull message)
Method to synchronously get a single message from a receiver by sending out a message to be responded to. |
void |
handleSendRequest(cMsgMessageFull msg)
Method to handle message sent by client. |
int |
handleSyncSendRequest(cMsgMessageFull msg)
Method to handle message sent by domain client in synchronous mode. |
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 |
hasSendAndGet()
Method to tell if the "sendAndGet" cMsg API function is implemented by this interface implementation in the handleSendAndGetRequest(org.jlab.coda.cMsg.cMsgMessageFull)
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. |
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 |
---|
handleClientShutdown, handleKeepAlive, handleShutdownClientsRequest, handleSubscribeAndGetRequest, handleSubscribeRequest, handleUnSendAndGetRequest, handleUnsubscribeAndGetRequest, handleUnsubscribeRequest, hasShutdown, hasSubscribe, hasSubscribeAndGet, hasUnsubscribe |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public FileQueue()
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 hasSendAndGet()
handleSendAndGetRequest(org.jlab.coda.cMsg.cMsgMessageFull)
method.
hasSendAndGet
in interface cMsgSubdomainInterface
hasSendAndGet
in class cMsgSubdomainAdapter
handleSendAndGetRequest(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 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
- upon errorpublic 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 handleSendAndGetRequest(cMsgMessageFull message) throws cMsgException
handleSendAndGetRequest
in interface cMsgSubdomainInterface
handleSendAndGetRequest
in class cMsgSubdomainAdapter
message
- message requesting what sort of message to get
cMsgException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |