Package org.astrogrid.samp.hub
Class BasicHubService
- java.lang.Object
-
- org.astrogrid.samp.hub.BasicHubService
-
- All Implemented Interfaces:
HubService
- Direct Known Subclasses:
GuiHubService
public class BasicHubService extends java.lang.Object implements HubService
HubService implementation.- Since:
- 15 Jul 2008
- Author:
- Mark Taylor
-
-
Field Summary
Fields Modifier and Type Field Description static int
MAX_TIMEOUT
The maximum timeout for a synchronous call permitted in seconds.static int
MAX_WAITERS
The maximum number of concurrently pending synchronous calls.
-
Constructor Summary
Constructors Constructor Description BasicHubService(java.util.Random random)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.String
call(HubClient caller, java.lang.String recipientId, java.lang.String msgTag, java.util.Map message)
Does the work for thecall
method of connections registered with this service.protected java.util.Map
callAll(HubClient caller, java.lang.String msgTag, java.util.Map message)
Does the work for thecall
method of connections registered with this service.protected Response
callAndWait(HubClient caller, java.lang.String recipientId, java.util.Map message, int timeout)
Does the work for thecallAndWait
method of connections registered with this service.protected HubClient
createClient(java.lang.String publicId, ProfileToken ptoken)
Factory method used to create all the client objects which will be used by this hub service.protected ClientSet
createClientSet()
Factory method used to create the client set used by this hub service.protected HubConnection
createConnection(HubClient caller)
Returns a new HubConnection for use by a given hub client.protected AbstractMessageHandler[]
createHubMessageHandlers()
Constructs a list of MessageHandlers to use for the client provided by the Hub.protected void
declareMetadata(HubClient caller, java.util.Map meta)
Does the work for thedeclareMetadata
method of connections registered with this service.protected void
declareSubscriptions(HubClient caller, java.util.Map subscriptions)
Does the work for thedeclareSubscriptions
method of connections registered with this service.void
disconnect(java.lang.String clientId, java.lang.String reason)
Forcibly disconnects a given client.void
disconnectAll(ProfileToken profileToken)
Forcibly terminates any connections created by a previous call ofHubService.register(org.astrogrid.samp.hub.ProfileToken)
with a particularprofileToken
.ClientSet
getClientSet()
Returns the structure which keeps track of registered clients.java.util.Comparator
getIdComparator()
Returns a comparator which will order client IDs.protected Metadata
getMetadata(HubClient caller, java.lang.String clientId)
Does the work for thegetMetadata
method of connections registered with this service.protected java.lang.String[]
getRegisteredClients(HubClient caller)
Does the work for thegetRegisteredClients
method of connections registered with this service.HubConnection
getServiceConnection()
Returns the HubConnection object used by the hub itself to send and receive messages.protected java.util.Map
getSubscribedClients(HubClient caller, java.lang.String mtype)
Does the work for thegetSubscribedClients
method of connections registered with this service.protected Subscriptions
getSubscriptions(HubClient caller, java.lang.String clientId)
Does the work for thegetSubscriptions
method of connections registered with this service.boolean
isHubRunning()
Indicates whether this hub service is currently open for operations.protected void
notify(HubClient caller, java.lang.String recipientId, java.util.Map message)
Does the work for thenotify
method of connections registered with this service.protected java.util.List
notifyAll(HubClient caller, java.util.Map message)
Does the work for thenotifyAll
method of connections registered with this service.HubConnection
register(ProfileToken ptoken)
Creates a new connection to this hub service, thereby initiating a new registered client.protected void
reply(HubClient caller, java.lang.String msgIdStr, java.util.Map resp)
Does the work for thereply
method of connections registered with this service.protected void
setCallable(HubClient caller, CallableClient callable)
Does the work for thesetCallable
method of connections registered with this service.void
shutdown()
Tidies up any resources owned by this object.void
start()
Begin operation.protected void
unregister(HubClient caller)
Does the work for theunregister
method of conections registered with this service.
-
-
-
Method Detail
-
start
public void start()
Description copied from interface:HubService
Begin operation. TheHubService.register(org.astrogrid.samp.hub.ProfileToken)
method should not be called until the hub has been started.- Specified by:
start
in interfaceHubService
-
createClientSet
protected ClientSet createClientSet()
Factory method used to create the client set used by this hub service.- Returns:
- client set
-
createClient
protected HubClient createClient(java.lang.String publicId, ProfileToken ptoken)
Factory method used to create all the client objects which will be used by this hub service.- Parameters:
publicId
- client public IDptoken
- connection source- Returns:
- hub client
-
createHubMessageHandlers
protected AbstractMessageHandler[] createHubMessageHandlers()
Constructs a list of MessageHandlers to use for the client provided by the Hub.- Returns:
- hub message handler list
-
getIdComparator
public java.util.Comparator getIdComparator()
Returns a comparator which will order client IDs. The ordering is in creation sequence.- Returns:
- public ID comparator
-
getClientSet
public ClientSet getClientSet()
Returns the structure which keeps track of registered clients.- Returns:
- client set
-
register
public HubConnection register(ProfileToken ptoken) throws SampException
Description copied from interface:HubService
Creates a new connection to this hub service, thereby initiating a new registered client.It is the responsibility of the returned connection, not the user of that connection, to broadcast the various
samp.hub.event.*
notifications at the appropriate times.Most of the
HubConnection
methods are declared to throwSampException
, however, implementations may throw unchecked exceptions if that is more convenient; users of the connection should be prepared to catch these if they occur.- Specified by:
register
in interfaceHubService
- Parameters:
ptoken
- identifier for the profile acting as gatekeeper for this connection- Returns:
- new hub connection representing registration of a new client
- Throws:
SampException
-
disconnectAll
public void disconnectAll(ProfileToken profileToken)
Description copied from interface:HubService
Forcibly terminates any connections created by a previous call ofHubService.register(org.astrogrid.samp.hub.ProfileToken)
with a particularprofileToken
. Any necessary hub events will be sent.- Specified by:
disconnectAll
in interfaceHubService
- Parameters:
profileToken
- previous argument toregister
-
createConnection
protected HubConnection createConnection(HubClient caller)
Returns a new HubConnection for use by a given hub client. The instance methods of the returned object delegate to similarly named protected methods of this BasicHubService object. These BasicHubService methods may therefore be overridden to modify the behaviour of such returned connections.- Parameters:
caller
- client requiring a connection- Returns:
- connection whose methods may be called by or on behalf of
caller
-
unregister
protected void unregister(HubClient caller) throws SampException
Does the work for theunregister
method of conections registered with this service.- Parameters:
caller
- client to unregister- Throws:
SampException
- See Also:
HubConnection.unregister()
-
setCallable
protected void setCallable(HubClient caller, CallableClient callable) throws SampException
Does the work for thesetCallable
method of connections registered with this service.- Parameters:
caller
- clientcallable
- callable object- Throws:
SampException
- See Also:
HubConnection.setCallable(org.astrogrid.samp.client.CallableClient)
-
declareMetadata
protected void declareMetadata(HubClient caller, java.util.Map meta) throws SampException
Does the work for thedeclareMetadata
method of connections registered with this service.- Parameters:
caller
- clientmeta
- new metadata for client- Throws:
SampException
- See Also:
HubConnection.declareMetadata(java.util.Map)
-
getMetadata
protected Metadata getMetadata(HubClient caller, java.lang.String clientId) throws SampException
Does the work for thegetMetadata
method of connections registered with this service.- Parameters:
caller
- calling clientclientId
- id of client being queried- Returns:
- metadata for client
- Throws:
SampException
- See Also:
HubConnection.getMetadata(java.lang.String)
-
declareSubscriptions
protected void declareSubscriptions(HubClient caller, java.util.Map subscriptions) throws SampException
Does the work for thedeclareSubscriptions
method of connections registered with this service.- Parameters:
caller
- clientsubscriptions
- new subscriptions for client- Throws:
SampException
- See Also:
HubConnection.declareSubscriptions(java.util.Map)
-
getSubscriptions
protected Subscriptions getSubscriptions(HubClient caller, java.lang.String clientId) throws SampException
Does the work for thegetSubscriptions
method of connections registered with this service.- Parameters:
caller
- calling clientclientId
- id of client being queried- Returns:
- subscriptions for client
- Throws:
SampException
- See Also:
HubConnection.getSubscriptions(java.lang.String)
-
getRegisteredClients
protected java.lang.String[] getRegisteredClients(HubClient caller) throws SampException
Does the work for thegetRegisteredClients
method of connections registered with this service.- Parameters:
caller
- calling client- Returns:
- array of registered client IDs excluding
caller
's - Throws:
SampException
- See Also:
HubConnection.getRegisteredClients()
-
getSubscribedClients
protected java.util.Map getSubscribedClients(HubClient caller, java.lang.String mtype) throws SampException
Does the work for thegetSubscribedClients
method of connections registered with this service.- Parameters:
caller
- calling clientmtype
- message type- Returns:
- map in which the keys are the public IDs of clients
subscribed to
mtype
- Throws:
SampException
- See Also:
HubConnection.getSubscribedClients(java.lang.String)
-
notify
protected void notify(HubClient caller, java.lang.String recipientId, java.util.Map message) throws SampException
Does the work for thenotify
method of connections registered with this service.- Parameters:
caller
- calling clientrecipientId
- public ID of client to receive messagemessage
- message- Throws:
SampException
- See Also:
HubConnection.notify(java.lang.String, java.util.Map)
-
call
protected java.lang.String call(HubClient caller, java.lang.String recipientId, java.lang.String msgTag, java.util.Map message) throws SampException
Does the work for thecall
method of connections registered with this service.- Parameters:
caller
- calling clientrecipientId
- client ID of recipientmsgTag
- message tagmessage
- message- Returns:
- message ID
- Throws:
SampException
- See Also:
HubConnection.call(java.lang.String, java.lang.String, java.util.Map)
-
notifyAll
protected java.util.List notifyAll(HubClient caller, java.util.Map message) throws SampException
Does the work for thenotifyAll
method of connections registered with this service.- Parameters:
caller
- calling clientmessage
- message- Returns:
- list of public IDs for clients to which the notify will be sent
- Throws:
SampException
- See Also:
HubConnection.notifyAll(java.util.Map)
-
callAll
protected java.util.Map callAll(HubClient caller, java.lang.String msgTag, java.util.Map message) throws SampException
Does the work for thecall
method of connections registered with this service.- Parameters:
caller
- calling clientmsgTag
- message tagmessage
- message- Returns:
- publicId->msgId map for clients to which an attempt to send the call will be made
- Throws:
SampException
- See Also:
HubConnection.callAll(java.lang.String, java.util.Map)
-
reply
protected void reply(HubClient caller, java.lang.String msgIdStr, java.util.Map resp) throws SampException
Does the work for thereply
method of connections registered with this service.- Parameters:
caller
- calling clientmsgIdStr
- message IDresp
- response to forward- Throws:
SampException
- See Also:
HubConnection.reply(java.lang.String, java.util.Map)
-
callAndWait
protected Response callAndWait(HubClient caller, java.lang.String recipientId, java.util.Map message, int timeout) throws SampException
Does the work for thecallAndWait
method of connections registered with this service.- Parameters:
caller
- calling clientrecipientId
- client ID of recipientmessage
- messagetimeout
- timeout in seconds- Returns:
- response response
- Throws:
SampException
- See Also:
HubConnection.callAndWait(java.lang.String, java.util.Map, int)
-
getServiceConnection
public HubConnection getServiceConnection()
Returns the HubConnection object used by the hub itself to send and receive messages. This is the one which apparently sends samp.hub.event.shutdown messages etc.- Returns:
- hub service's own hub connection
-
disconnect
public void disconnect(java.lang.String clientId, java.lang.String reason)
Forcibly disconnects a given client. This call does three things:- sends a
samp.hub.disconnect
message to the client which is about to be ejected, if the client is subscribed to that MType - removes that client from this hub's client set so that any further communication attempts to or from it will fail
- broadcasts a
samp.hub.unregister
message to all remaining clients indicating that the client has disappeared
- Parameters:
clientId
- public-id of client to ejectreason
- short text string indicating reason for ejection
- sends a
-
isHubRunning
public boolean isHubRunning()
Description copied from interface:HubService
Indicates whether this hub service is currently open for operations.- Specified by:
isHubRunning
in interfaceHubService
- Returns:
- true iff called between
HubService.start()
andHubService.shutdown()
-
shutdown
public void shutdown()
Description copied from interface:HubService
Tidies up any resources owned by this object. Should be called when no longer required.- Specified by:
shutdown
in interfaceHubService
-
-