cgl.narada.samples.nbNative
Class TDSClient

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

All Implemented Interfaces:

NBEventListener, NBRecoveryListener, ReplayServiceListener

public class TDSClient
extends Object
implements NBEventListener, NBRecoveryListener, ReplayServiceListener

Constructor Summary

TDSClient(int entityId)

Method Summary

void	closeBrokerConnection()
void	initializeBrokerCommunications(Properties props, String commType)
void	initializeConsumer()
void	initializeConsumerWithTDS()
void	initializeProducer()
void	initiateReplay(long start, long stop)
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	onReplay(ReplayEvent replayEvent)
void	onReplayResponse(ReplayResponse replayResponse)
void	processEventProperties(NBEvent nbEvent)
void	publishEvent(String stringMsg)
void	unsubscribe()

Methods inherited from class java.lang.Object

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

Constructor Detail

TDSClient

public TDSClient(int entityId)

Method Detail

initializeBrokerCommunications

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

Throws:

ServiceException

closeBrokerConnection

public void closeBrokerConnection()
                           throws ServiceException

Throws:

ServiceException

initializeProducer

public void initializeProducer()
                        throws ServiceException

Throws:

ServiceException

initializeConsumer

public void initializeConsumer()
                        throws ServiceException

Throws:

ServiceException

initializeConsumerWithTDS

public void initializeConsumerWithTDS()
                               throws ServiceException

Throws:

ServiceException

unsubscribe

public void unsubscribe()
                 throws ServiceException

Throws:

ServiceException

initiateReplay

public void initiateReplay(long start,
                           long stop)
                    throws ServiceException

Throws:

ServiceException

onReplay

public void onReplay(ReplayEvent replayEvent)

Specified by:

onReplay in interface ReplayServiceListener

onReplayResponse

public void onReplayResponse(ReplayResponse replayResponse)

Specified by:

onReplayResponse in interface ReplayServiceListener

publishEvent

public void publishEvent(String stringMsg)
                  throws ServiceException,
                         NBEventException

Throws:

ServiceException

NBEventException

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

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

processEventProperties

public void processEventProperties(NBEvent nbEvent)
                            throws NBEventException

Throws:

NBEventException

main

public static void main(String[] args)