public class LoadGenerator
extends java.lang.Object
Constructor and Description |
---|
LoadGenerator() |
Modifier and Type | Method and Description |
---|---|
void |
closeBrokerConnection()
Closes the connection to the broker.
|
void |
initializeBrokerCommunications(java.util.Properties props,
java.lang.String commType) |
void |
initializeConsumer() |
void |
initializeProducer() |
static void |
main(java.lang.String[] args) |
void |
onEvent(NBEvent nbEvent) |
void |
publishEvent(byte[] transferBytes) |
void |
publishEvent(java.lang.String stringMsg) |
void |
unsubscribe() |
public LoadGenerator() throws ServiceException
ServiceException
public void initializeBrokerCommunications(java.util.Properties props, java.lang.String commType) throws ServiceException
ServiceException
public void closeBrokerConnection() throws ServiceException
ServiceException
public void initializeProducer() throws ServiceException
ServiceException
public void initializeConsumer() throws ServiceException
ServiceException
public void unsubscribe() throws ServiceException
ServiceException
public void publishEvent(java.lang.String stringMsg) throws ServiceException, NBEventException
ServiceException
NBEventException
public void publishEvent(byte[] transferBytes) throws ServiceException, NBEventException
ServiceException
NBEventException
public void onEvent(NBEvent nbEvent)
public static void main(java.lang.String[] args)