cgl.narada.samples.nbNative
Class ReplayClient

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

All Implemented Interfaces:

NBEventListener, ReplayServiceListener

public class ReplayClient
extends Object
implements NBEventListener, ReplayServiceListener

A simple native client of NaradaBrokering

Constructor Summary

ReplayClient(int entityId)

Method Summary

void	initializeBrokerCommunications(Properties props, String commType)
void	initializeConsumer()
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	onReplay(ReplayEvent replayEvent)
void	onReplayResponse(ReplayResponse replayResponse)
void	performReplay(int templateId, long start, long end)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplayClient

public ReplayClient(int entityId)

Method Detail

initializeBrokerCommunications

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

Throws:

ServiceException

initializeConsumer

public void initializeConsumer()
                        throws ServiceException

Throws:

ServiceException

performReplay

public void performReplay(int templateId,
                          long start,
                          long end)
                   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

onReplay

public void onReplay(ReplayEvent replayEvent)

Specified by:

onReplay in interface ReplayServiceListener

onReplayResponse

public void onReplayResponse(ReplayResponse replayResponse)

Specified by:

onReplayResponse in interface ReplayServiceListener

main

public static void main(String[] args)