org.jlab.coda.cMsg.cMsgDomain.subdomains

Class SmartSockets

java.lang.Object

org.jlab.coda.cMsg.common.cMsgSubdomainAdapter

org.jlab.coda.cMsg.cMsgDomain.subdomains.SmartSockets

All Implemented Interfaces:

cMsgSubdomainInterface

public class SmartSockets
extends cMsgSubdomainAdapter

cMsg subdomain handler for smartsockets subdomain. Implements proxy smartsockets server.

UDL: cMsg:cMsg://host:port/SmartSockets/projectName

Version:

1.0

Author:

Elliott Wolin

Constructor Summary

Constructors

Constructor and Description
SmartSockets()

Method Summary

Modifier and Type	Method and Description
void	handleClientShutdown() Close connection to smartsockets server.
void	handleSendRequest(cMsgMessageFull msg) Forwards message to smartsockets system.
void	handleSubscribeRequest(java.lang.String subject, java.lang.String type, int id) Subscribe to receive smartsockets messages.
void	handleUnsubscribeRequest(java.lang.String subject, java.lang.String type, int id) Unsubscribe smartsockets subscription.
boolean	hasSend() Method to tell if the "send" cMsg API function is implemented by this interface implementation in the "handleSendRequest" method.
boolean	hasSubscribe() Method to tell if the "subscribe" cMsg API function is implemented by this interface implementation in the "handleSubscribeRequest" method.
boolean	hasUnsubscribe() Method to tell if the "unsubscribe" cMsg API function is implemented by this interface implementation in the "handleUnsubscribeRequest" method.
void	registerClient(cMsgClientInfo info) Connect to smartsockets server.
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.common.cMsgSubdomainAdapter

handleSendAndGetRequest, handleShutdownClientsRequest, handleSubscribeAndGetRequest, handleSyncSendRequest, handleUnSendAndGetRequest, handleUnsubscribeAndGetRequest, hasSendAndGet, hasShutdown, hasSubscribeAndGet, hasSyncSend

Methods inherited from class java.lang.Object

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

Constructor Detail

SmartSockets

public SmartSockets()

Method Detail

hasSend

public boolean hasSend()

Method to tell if the "send" cMsg API function is implemented by this interface implementation in the "handleSendRequest" method.

Specified by:

hasSend in interface cMsgSubdomainInterface

Overrides:

hasSend in class cMsgSubdomainAdapter

Returns:

true

hasSubscribe

public boolean hasSubscribe()

Method to tell if the "subscribe" cMsg API function is implemented by this interface implementation in the "handleSubscribeRequest" method.

Specified by:

hasSubscribe in interface cMsgSubdomainInterface

Overrides:

hasSubscribe in class cMsgSubdomainAdapter

Returns:

true

hasUnsubscribe

public boolean hasUnsubscribe()

Method to tell if the "unsubscribe" cMsg API function is implemented by this interface implementation in the "handleUnsubscribeRequest" method.

Specified by:

hasUnsubscribe in interface cMsgSubdomainInterface

Overrides:

hasUnsubscribe in class cMsgSubdomainAdapter

Returns:

true

setUDLRemainder

public void setUDLRemainder(java.lang.String UDLRemainder)
                     throws cMsgException

Method to give the subdomain handler the appropriate part of the UDL the client used to talk to the domain server.

Specified by:

setUDLRemainder in interface cMsgSubdomainInterface

Overrides:

setUDLRemainder in class cMsgSubdomainAdapter

Parameters:

UDLRemainder - last part of the UDL appropriate to the subdomain handler

Throws:

cMsgException - never

registerClient

public void registerClient(cMsgClientInfo info)
                    throws cMsgException

Connect to smartsockets server.

Specified by:

registerClient in interface cMsgSubdomainInterface

Overrides:

registerClient in class cMsgSubdomainAdapter

Parameters:

info - contains all client info

Throws:

cMsgException - if cannot connect to smartsockets server

handleSendRequest

public void handleSendRequest(cMsgMessageFull msg)
                       throws cMsgException

Forwards message to smartsockets system.

Specified by:

handleSendRequest in interface cMsgSubdomainInterface

Overrides:

handleSendRequest in class cMsgSubdomainAdapter

Parameters:

msg - message from sender

Throws:

cMsgException - if cannot forward message

handleSubscribeRequest

public void handleSubscribeRequest(java.lang.String subject,
                                   java.lang.String type,
                                   int id)
                            throws cMsgException

Subscribe to receive smartsockets messages.

Specified by:

handleSubscribeRequest in interface cMsgSubdomainInterface

Overrides:

handleSubscribeRequest in class cMsgSubdomainAdapter

Parameters:

subject - subject subscribed to

type - type subscribed to

id - unique id

Throws:

cMsgException - if cannot subscribe

handleUnsubscribeRequest

public void handleUnsubscribeRequest(java.lang.String subject,
                                     java.lang.String type,
                                     int id)

Unsubscribe smartsockets subscription.

Specified by:

handleUnsubscribeRequest in interface cMsgSubdomainInterface

Overrides:

handleUnsubscribeRequest in class cMsgSubdomainAdapter

Parameters:

subject - subject of subscription

type - type of subscription

id - unique id

handleClientShutdown

public void handleClientShutdown()
                          throws cMsgException

Close connection to smartsockets server.

Specified by:

handleClientShutdown in interface cMsgSubdomainInterface

Overrides:

handleClientShutdown in class cMsgSubdomainAdapter

Throws:

cMsgException - never