cgl.narada.jms
Class NBJmsInterconnectionBridge

java.lang.Object
  cgl.narada.jms.NBJmsInterconnectionBridge

All Implemented Interfaces:

NBEventListener, NBRecoveryListener

public class NBJmsInterconnectionBridge
extends Object
implements NBEventListener, NBRecoveryListener

This class provides the bridge for JMS calls into the NaradaBrokering system.

Constructor Summary

NBJmsInterconnectionBridge(Properties bridgeProperties, String commType, int entityId)

Method Summary

void	closeConnection()
void	initializeConsumer(String subscription, boolean isDurable)
void	onEvent(NBEvent nbEvent) Upon the receipt of an event which has satisfied all the constraints, if any were provided, that needed to be satisfied prior to delivery
void	onRecovery(NBRecoveryNotification recoveryNotification) Upon completion of the attempt to recover, this method is invoked on the listener that was registered with the
void	publishEvent(JmsEvent jmsEvent)
void	setJmsTopicConnection(JmsTopicConnection jmsTopicConnection)
void	unSubscribeConsumer(String subscription)

Methods inherited from class java.lang.Object

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

Constructor Detail

NBJmsInterconnectionBridge

public NBJmsInterconnectionBridge(Properties bridgeProperties,
                                  String commType,
                                  int entityId)
                           throws JMSException

Throws:

JMSException

Method Detail

setJmsTopicConnection

public void setJmsTopicConnection(JmsTopicConnection jmsTopicConnection)

unSubscribeConsumer

public void unSubscribeConsumer(String subscription)
                         throws JMSException

Throws:

JMSException

initializeConsumer

public void initializeConsumer(String subscription,
                               boolean isDurable)
                        throws JMSException

Throws:

JMSException

publishEvent

public void publishEvent(JmsEvent jmsEvent)
                  throws JMSException

Throws:

JMSException

onEvent

public void onEvent(NBEvent nbEvent)

Description copied from interface: NBEventListener

Upon the receipt of an event which has satisfied all the constraints, if any were provided, that needed to be satisfied prior to delivery

Specified by:

onEvent in interface NBEventListener

onRecovery

public void onRecovery(NBRecoveryNotification recoveryNotification)

Upon completion of the attempt to recover, this method is invoked on the listener that was registered with the

Specified by:

onRecovery in interface NBRecoveryListener

closeConnection

public void closeConnection()
                     throws JMSException

Throws:

JMSException