cgl.narada.samples.nbNative
Class RobustPublisher

java.lang.Object
  extended by cgl.narada.samples.nbNative.RobustPublisher
All Implemented Interfaces:
NBEventListener, NBRecoveryListener

public class RobustPublisher
extends Object
implements NBEventListener, NBRecoveryListener

A simple native client of NaradaBrokering


Constructor Summary
RobustPublisher(int entityId)
           
 
Method Summary
 void initializeBrokerCommunications(Properties props, String commType)
           
 void initializeProducerAndConsumer(int templateId)
           
static void main(String[] args)
           
 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(String stringMsg)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RobustPublisher

public RobustPublisher(int entityId)
Method Detail

initializeBrokerCommunications

public void initializeBrokerCommunications(Properties props,
                                           String commType)
                                    throws ServiceException
Throws:
ServiceException

initializeProducerAndConsumer

public void initializeProducerAndConsumer(int templateId)
                                   throws ServiceException
Throws:
ServiceException

publishEvent

public void publishEvent(String stringMsg)
                  throws ServiceException
Throws:
ServiceException

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

main

public static void main(String[] args)


For comments and suggestions please send e-mail to The NaradaBrokering Project