cgl.narada.samples.nbNative
Class FragmentationClient

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

All Implemented Interfaces:

NBRecoveryListener, ServiceBulletin

public class FragmentationClient
extends Object
implements NBRecoveryListener, ServiceBulletin

A client demonstrating fragmentation capabilities with NaradaBrokering.

Constructor Summary

FragmentationClient(int entityId)

Method Summary

void	initializeBrokerCommunications(Properties props, String commType)
void	initializeProducer(int templateId, String templateSynopsis)
static void	main(String[] args)
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)
void	publishEvent(String stringMsg, Properties fragmentationProperties)

Methods inherited from class java.lang.Object

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

Constructor Detail

FragmentationClient

public FragmentationClient(int entityId)

Method Detail

initializeBrokerCommunications

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

Throws:

ServiceException

initializeProducer

public void initializeProducer(int templateId,
                               String templateSynopsis)
                        throws ServiceException

Throws:

ServiceException

publishEvent

public void publishEvent(String stringMsg,
                         Properties fragmentationProperties)
                  throws ServiceException

Throws:

ServiceException

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)