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(long num) |
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(long num) throws ServiceException, NBEventException, MarshallingException
ServiceException
NBEventException
MarshallingException
public void publishEvent(byte[] transferBytes) throws ServiceException, NBEventException
ServiceException
NBEventException
public void onEvent(NBEvent nbEvent)
public static void main(java.lang.String[] args)