cgl.narada.samples.nbNative
Class CoalescingClient

java.lang.Object
  cgl.narada.samples.nbNative.CoalescingClient

All Implemented Interfaces:

NBEventListener, NBRecoveryListener, ServiceBulletin

public class CoalescingClient
extends Object
implements NBEventListener, NBRecoveryListener, ServiceBulletin

A coalescing native client of NaradaBrokering

Constructor Summary

CoalescingClient(int entityId)

Method Summary

void	initializeBrokerCommunications(Properties props, String commType)
void	initializeConsumer(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	onServiceException(ServiceException serviceException)
void	onServiceNotification(ServiceNotification serviceNotification)

Methods inherited from class java.lang.Object

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

Constructor Detail

CoalescingClient

public CoalescingClient(int entityId)

Method Detail

initializeBrokerCommunications

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

Throws:

ServiceException

initializeConsumer

public void initializeConsumer(int templateId)
                        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

onServiceException

public void onServiceException(ServiceException serviceException)

Specified by:

onServiceException in interface ServiceBulletin

onServiceNotification

public void onServiceNotification(ServiceNotification serviceNotification)

Specified by:

onServiceNotification in interface ServiceBulletin

main

public static void main(String[] args)