cgl.narada.samples.nbNative
Class SimpleHierarchicalClient

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

All Implemented Interfaces:

NBEventListener

public class SimpleHierarchicalClient
extends Object
implements NBEventListener

A simple native client of NaradaBrokering

Constructor Summary

SimpleHierarchicalClient(int entityId)

Method Summary

void	addEventProperty()
void	closeBrokerConnection() Closes the connection to the broker.
void	initializeBrokerCommunications(Properties props, String commType)
void	initializeConsumer()
void	initializeProducer()
void	initializeTopics(String pubTopic, String subscriberTopic)
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	publishEvent(String stringMsg)
void	removeEventProperty()
void	unsubscribe()

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleHierarchicalClient

public SimpleHierarchicalClient(int entityId)

Method Detail

initializeBrokerCommunications

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

Throws:

ServiceException

closeBrokerConnection

public void closeBrokerConnection()
                           throws ServiceException

Closes the connection to the broker.

Throws:

ServiceException

initializeProducer

public void initializeProducer()
                        throws ServiceException

Throws:

ServiceException

initializeTopics

public void initializeTopics(String pubTopic,
                             String subscriberTopic)
                      throws ServiceException

Throws:

ServiceException

initializeConsumer

public void initializeConsumer()
                        throws ServiceException

Throws:

ServiceException

unsubscribe

public void unsubscribe()
                 throws ServiceException

Throws:

ServiceException

addEventProperty

public void addEventProperty()

removeEventProperty

public void removeEventProperty()

publishEvent

public void publishEvent(String stringMsg)
                  throws ServiceException,
                         NBEventException

Throws:

ServiceException

NBEventException

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

main

public static void main(String[] args)