Field Detail

• connection_

  private final HubConnection connection_

• handlers_

  private final AbstractMessageHandler[] handlers_

Constructor Detail

• HubCallableClient

  public HubCallableClient(HubConnection connection,
                           AbstractMessageHandler[] handlers)

  Constructs a HubCallableClient with a given set of handlers.

  Parameters:

  connection - connection to hub service

  handlers - array of message handlers

Method Detail

• receiveCall

  public void receiveCall(java.lang.String senderId,
                          java.lang.String msgId,
                          Message msg)
                   throws SampException

  Description copied from interface: CallableClient
  Receives a message for which a response is required. The implementation must take care to call the hub's reply method at some future point.

  Specified by:

  receiveCall in interface CallableClient

  Parameters:

  senderId - public ID of sending client

  msgId - message identifier for later use with reply

  msg - message

  Throws:

  SampException

• receiveNotification

  public void receiveNotification(java.lang.String senderId,
                                  Message msg)
                           throws SampException

  Description copied from interface: CallableClient
  Receives a message for which no response is required.

  Specified by:

  receiveNotification in interface CallableClient

  Parameters:

  senderId - public ID of sending client

  msg - message

  Throws:

  SampException

• receiveResponse

  public void receiveResponse(java.lang.String responderId,
                              java.lang.String msgTag,
                              Response response)
                       throws SampException

  Description copied from interface: CallableClient
  Receives a response to a message previously sent by this client.

  Specified by:

  receiveResponse in interface CallableClient

  Parameters:

  responderId - public ID of responding client

  msgTag - client-defined tag labelling previously-sent message

  response - returned response object

  Throws:

  SampException

• getSubscriptions

  public Subscriptions getSubscriptions()

  Returns the subscriptions corresponding to the messages that this receiver can deal with.

  Returns:

  subscriptions list

• getHandler

  private AbstractMessageHandler getHandler(java.lang.String mtype)
                                     throws SampException

  Returns a handler owned by this callable client which can handle a given MType. If more than one applies, the first one encountered is returned.

  Parameters:

  mtype - MType to handle

  Returns:

  handler for mtype

  Throws:

  SampException - if no suitable handler exists