public class NumberGenerator
extends java.lang.Object
Constructor and Description |
---|
NumberGenerator(int numberOfBuckets) |
Modifier and Type | Method and Description |
---|---|
void |
closeBrokerConnection()
Closes the connection to the broker.
|
void |
generate(int numbersToGenerate) |
void |
initializeBrokerCommunications(java.util.Properties props,
java.lang.String commType) |
void |
initializeProducer() |
static void |
main(java.lang.String[] args) |
void |
publishComputeCommand() |
void |
publishEvent(java.lang.String publishingTopic,
long[] generatedNumbers) |
public NumberGenerator(int numberOfBuckets) throws ServiceException
ServiceException
public void generate(int numbersToGenerate) throws ServiceException, NBEventException, java.io.IOException, MarshallingException
ServiceException
NBEventException
java.io.IOException
MarshallingException
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 publishComputeCommand() throws ServiceException, NBEventException, java.io.IOException
ServiceException
NBEventException
java.io.IOException
public void publishEvent(java.lang.String publishingTopic, long[] generatedNumbers) throws ServiceException, NBEventException, java.io.IOException, MarshallingException
ServiceException
NBEventException
java.io.IOException
MarshallingException
public static void main(java.lang.String[] args)