public class LoadGenerator
extends java.lang.Object
Constructor and Description |
---|
LoadGenerator(java.util.Properties property) |
Modifier and Type | Method and Description |
---|---|
void |
closeBrokerConnection()
Closes the connection to the broker.
|
void |
createEvent(java.lang.String topic,
byte[] message) |
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(java.lang.String publishTopic,
byte[] msg) |
public LoadGenerator(java.util.Properties property) throws ServiceException
ServiceException
public void initializeConsumer() 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 publishEvent(java.lang.String publishTopic, byte[] msg) throws ServiceException, NBEventException
ServiceException
NBEventException
public void onEvent(NBEvent nbEvent)
public void createEvent(java.lang.String topic, byte[] message) throws ServiceException, NBEventException
ServiceException
NBEventException
public static void main(java.lang.String[] args)
args
- args[0] is the host name of narada brokering. args[1] is the
port number of narada brokering.