com.resilientedge.jockey.peerbridge
Class MessageBrokerBridge

java.lang.Object
  |
  +--com.resilientedge.jockey.peerbridge.MessageBrokerBridge

All Implemented Interfaces:

PBMessageObserver

public class MessageBrokerBridge

extends java.lang.Object

implements PBMessageObserver

The MessageBrokerBridge converts MessageBroker calls into peerbridge calls.

Version:

$Revision: 1.1.1.1 $

Author:

John Gardner

See Also:

MessageBrokerImpl

Method Summary

void	clearInterest(MessageBrokerImpl impl) Remove the input object as interested in receiving updates.
static MessageBrokerBridge	getInstance(PeerGroupToken group) Returns the singleton instance
void	incomingMessageUpdate(PBReceiveMarker receiveMarker) Called when an incoming message being received has a status update.
void	onMessage(PBMessage message) Called when a message was successfully sent.
void	onMessageCancelled(PBReceiveMarker marker) Called when a message has been cancelled
void	onMessageCancelled(PBSendMarker sendMarker) Called when a message has been cancelled
void	onMessageSent(PBSendMarker sendMarker) Called when a message has been successfully sent
void	onRequest(PBMessage request) Called when a request has been received and is ready to be processed.
void	onRequestCancelled(PBReceiveMarker marker) Called when a request has been cancelled
void	onResponse(PBResponseMarker responseMarker, PBMessage response) Called when a response has been received
void	onTimeout(PBResponseMarker responseMarker) Called when a message has been timeout
ResponseMarker	sendAsyncRequest(AppToken app, PeerMessage request, int timeout) Sends an asynchronous request to a peer, informing the registered MessageListener when the response is received or the timeout has been exceeded.
SendMarker	sendMessage(AppToken app, PeerMessage message) Sends a message asynchronously, returning a SendMarker for tracking the progress of the message transmission.
PeerMessage	sendRequest(AppToken app, PeerMessage request, int timeout) Sends a request to a peer, waiting until the response is received or until the timeout is exceeded.
SendMarker	sendResponse(PeerMessage request, PeerMessage message) Sends an asynchronous reply to a peer's request, informing the registered MessageListener when the send has completed.
void	setInterest(MessageBrokerImpl impl) Marks the input object as interested in receiving updates.

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static MessageBrokerBridge getInstance(PeerGroupToken group)

Returns the singleton instance

Returns:

The Instance value

sendMessage

public SendMarker sendMessage(AppToken app,
                              PeerMessage message)
                       throws java.io.IOException

Sends a message asynchronously, returning a SendMarker for tracking the progress of the message transmission.

Parameters:

app - app to receive request

message - message to send

Returns:

marker to identify send progress

sendRequest

public PeerMessage sendRequest(AppToken app,
                               PeerMessage request,
                               int timeout)
                        throws java.io.IOException

Sends a request to a peer, waiting until the response is received or until the timeout is exceeded.

Parameters:

app - app to receive request

request - request to send

timeout - time (in seconds) to wait for response

Returns:

response message from app

sendAsyncRequest

public ResponseMarker sendAsyncRequest(AppToken app,
                                       PeerMessage request,
                                       int timeout)
                                throws java.io.IOException

Sends an asynchronous request to a peer, informing the registered MessageListener when the response is received or the timeout has been exceeded.

Parameters:

app - app to receive request

request - request to send

timeout - time (in seconds) to wait for response

Returns:

marker to identify matching response

sendResponse

public SendMarker sendResponse(PeerMessage request,
                               PeerMessage message)
                        throws java.io.IOException

Sends an asynchronous reply to a peer's request, informing the registered MessageListener when the send has completed.

Parameters:

request - request which was received

message - message to send

Returns:

marker to identify send progress

incomingMessageUpdate

public void incomingMessageUpdate(PBReceiveMarker receiveMarker)

Called when an incoming message being received has a status update.

Specified by:

incomingMessageUpdate in interface PBMessageObserver

Parameters:

receiveMarker - Description of Parameter

onMessage

public void onMessage(PBMessage message)

Called when a message was successfully sent.

Specified by:

onMessage in interface PBMessageObserver

Parameters:

message - Description of Parameter

onMessageCancelled

public void onMessageCancelled(PBReceiveMarker marker)

Called when a message has been cancelled

Specified by:

onMessageCancelled in interface PBMessageObserver

Parameters:

marker - Description of Parameter

onRequest

public void onRequest(PBMessage request)

Called when a request has been received and is ready to be processed.

Specified by:

onRequest in interface PBMessageObserver

Parameters:

request - Description of Parameter

onRequestCancelled

public void onRequestCancelled(PBReceiveMarker marker)

Called when a request has been cancelled

Specified by:

onRequestCancelled in interface PBMessageObserver

Parameters:

marker - Description of Parameter

onMessageSent

public void onMessageSent(PBSendMarker sendMarker)

Called when a message has been successfully sent

Specified by:

onMessageSent in interface PBMessageObserver

Parameters:

sendMarker - Description of Parameter

onMessageCancelled

public void onMessageCancelled(PBSendMarker sendMarker)

Called when a message has been cancelled

Specified by:

onMessageCancelled in interface PBMessageObserver

Parameters:

sendMarker - Description of Parameter

onResponse

public void onResponse(PBResponseMarker responseMarker,
                       PBMessage response)

Called when a response has been received

Specified by:

onResponse in interface PBMessageObserver

Parameters:

responseMarker - Description of Parameter

response - Description of Parameter

onTimeout

public void onTimeout(PBResponseMarker responseMarker)

Called when a message has been timeout

Specified by:

onTimeout in interface PBMessageObserver

Parameters:

responseMarker - Description of Parameter

setInterest

public void setInterest(MessageBrokerImpl impl)

Marks the input object as interested in receiving updates.

Parameters:

MessageBrokerImpl - interested object

clearInterest

public void clearInterest(MessageBrokerImpl impl)

Remove the input object as interested in receiving updates.

Parameters:

MessageBrokerImpl - interested object