public class PyLoadGenRep
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
java.lang.String |
rdcrTopic |
Constructor and Description |
---|
PyLoadGenRep() |
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 arg0) |
void |
publishEvent(byte[] msg) |
void |
publishEvent(byte[] msg,
java.lang.String publishTopic) |
void |
unsubscribe() |
public PyLoadGenRep() 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(byte[] msg) throws ServiceException, NBEventException, MarshallingException
ServiceException
NBEventException
MarshallingException
public void publishEvent(byte[] msg, java.lang.String publishTopic) throws ServiceException
ServiceException
public void onEvent(NBEvent arg0)
public static void main(java.lang.String[] args)