org.hobbit.core.components

Class AbstractDataGenerator

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.AbstractDataGenerator

All Implemented Interfaces:

Closeable, AutoCloseable, CommandReceivingComponent, Component, PlatformConnector, RabbitQueueFactory

public abstract class AbstractDataGenerator
extends AbstractPlatformConnectorComponent

Field Summary

Fields

Modifier and Type	Field and Description
protected RabbitQueue	dataGen2SystemQueue
protected RabbitQueue	dataGen2TaskGenQueue
private int	generatorId
private static org.slf4j.Logger	LOGGER
private int	numberOfGenerators
private Semaphore	startDataGenMutex

Fields inherited from class org.hobbit.core.components.AbstractCommandReceivingComponent

cmdChannel, defaultContainerType

Fields inherited from class org.hobbit.core.components.AbstractComponent

connection, NUMBER_OF_RETRIES_TO_CONNECT_TO_RABBIT_MQ, rabbitMQHostName, START_WAITING_TIME_BEFORE_RETRY

Constructor Summary

Constructors

Constructor and Description
AbstractDataGenerator()

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract void	generateData()
int	getGeneratorId()
int	getNumberOfGenerators()
void	init() This method initializes the component.
void	receiveCommand(byte command, byte[] data) This method is called if a command is received and might be interesting for this particular component.
void	run() This method executes the component.
protected void	sendDataToSystemAdapter(byte[] data)
protected void	sendDataToTaskGenerator(byte[] data)

Methods inherited from class org.hobbit.core.components.AbstractPlatformConnectorComponent

createContainer, createDefaultRabbitQueue, stopContainer

Methods inherited from class org.hobbit.core.components.AbstractCommandReceivingComponent

addCommandHeaderId, createContainer, createContainer, handleCmd, sendToCmdQueue, sendToCmdQueue, sendToCmdQueue

Methods inherited from class org.hobbit.core.components.AbstractComponent

generateSessionQueueName, getHobbitSessionId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

startDataGenMutex

private Semaphore startDataGenMutex

generatorId

private int generatorId

numberOfGenerators

private int numberOfGenerators

dataGen2TaskGenQueue

protected RabbitQueue dataGen2TaskGenQueue

dataGen2SystemQueue

protected RabbitQueue dataGen2SystemQueue

Constructor Detail

AbstractDataGenerator

public AbstractDataGenerator()

Method Detail

init

public void init()
          throws Exception

Description copied from interface: Component

This method initializes the component.

Specified by:

init in interface Component

Overrides:

init in class AbstractCommandReceivingComponent

Throws:

Exception - if an error occurs during the initialization

run

public void run()
         throws Exception

Description copied from interface: Component

This method executes the component.

Throws:

Exception - if an error occurs during the execution

generateData

protected abstract void generateData()
                              throws Exception

Throws:

Exception

receiveCommand

public void receiveCommand(byte command,
                           byte[] data)

Description copied from interface: CommandReceivingComponent

This method is called if a command is received and might be interesting for this particular component.

Specified by:

receiveCommand in interface CommandReceivingComponent

Overrides:

receiveCommand in class AbstractPlatformConnectorComponent

Parameters:

command - the byte encoding the command

data - additional data that was sent together with the command

sendDataToTaskGenerator

protected void sendDataToTaskGenerator(byte[] data)
                                throws IOException

Throws:

IOException

sendDataToSystemAdapter

protected void sendDataToSystemAdapter(byte[] data)
                                throws IOException

Throws:

IOException

getGeneratorId

public int getGeneratorId()

getNumberOfGenerators

public int getNumberOfGenerators()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractCommandReceivingComponent

Throws:

IOException