org.hobbit.core.components

Class AbstractTaskGenerator

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.stream.AbstractStreamingTaskGenerator

org.hobbit.core.components.AbstractTaskGenerator

All Implemented Interfaces:

Closeable, AutoCloseable, CommandReceivingComponent, Component, GeneratedDataReceivingComponent, PlatformConnector, StreamingGeneratedDataReceivingComponent

Direct Known Subclasses:

AbstractSequencingTaskGenerator

public abstract class AbstractTaskGenerator
extends AbstractStreamingTaskGenerator
implements GeneratedDataReceivingComponent

This abstract class implements basic functions that can be used to implement a task generator. The following environment variables are expected:

• Constants.GENERATOR_ID_KEY
• Constants.GENERATOR_COUNT_KEY

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Nested Class Summary

Nested classes/interfaces inherited from class org.hobbit.core.components.stream.AbstractStreamingTaskGenerator

AbstractStreamingTaskGenerator.GeneratedDataHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOGGER

Fields inherited from class org.hobbit.core.components.stream.AbstractStreamingTaskGenerator

dataReceiver, generatorId, numberOfGenerators, sender2EvalStore, sender2System

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

cmdChannel, cmdQueueFactory, DEFAULT_CMD_RESPONSE_TIMEOUT, defaultContainerType

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

connectionFactory, incomingDataQueueFactory, NUMBER_OF_RETRIES_TO_CONNECT_TO_RABBIT_MQ, outgoingDataQueuefactory, rabbitMQHostName, START_WAITING_TIME_BEFORE_RETRY

Constructor Summary

Constructors

Constructor and Description
AbstractTaskGenerator() Default constructor creating an AbstractTaskGenerator processing up to AbstractStreamingTaskGenerator.DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES= messages in parallel.
AbstractTaskGenerator(int maxParallelProcessedMsgs) Constructor setting the maximum number of parallel processed messages.

Method Summary

Modifier and Type	Method and Description
protected abstract void	generateTask(byte[] data) Generates a task from the given data, sends it to the system, takes the timestamp of the moment at which the message has been sent to the system and sends it together with the expected response to the evaluation storage.
void	generateTask(InputStream dataStream) Generates a task from the given data, sends it to the system, takes the timestamp of the moment at which the message has been sent to the system and sends it together with the expected response to the evaluation storage.
void	receiveGeneratedData(byte[] data) This method is called if data is received from a data generator.
protected void	sendTaskToEvalStorage(String taskIdString, long timestamp, byte[] data) This method sends the given data and the given timestamp of the task with the given task id to the evaluation storage.
protected void	sendTaskToSystemAdapter(String taskIdString, byte[] data) Sends the given task with the given task id and data to the system.

Methods inherited from class org.hobbit.core.components.stream.AbstractStreamingTaskGenerator

close, getGeneratorId, getNextTaskId, getNumberOfGenerators, init, receiveCommand, receiveGeneratedData, run, sendTaskToEvalStorage, sendTaskToSystemAdapter

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

addContainerObserver, createContainer, getFactoryForIncomingCmdQueues, getFactoryForIncomingDataQueues, getFactoryForOutgoingCmdQueues, getFactoryForOutgoingDataQueues, 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

createConnection, generateSessionQueueName, getHobbitSessionId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hobbit.core.components.stream.StreamingGeneratedDataReceivingComponent

receiveGeneratedData

Methods inherited from interface org.hobbit.core.components.Component

init, run

Methods inherited from interface java.io.Closeable

close

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

Constructor Detail

AbstractTaskGenerator

public AbstractTaskGenerator()

Default constructor creating an AbstractTaskGenerator processing up to AbstractStreamingTaskGenerator.DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES= messages in parallel.

AbstractTaskGenerator

public AbstractTaskGenerator(int maxParallelProcessedMsgs)

Constructor setting the maximum number of parallel processed messages. Note that this parameter has to be larger or equal to 1 or the AbstractStreamingTaskGenerator.init() method will throw an exception. Setting maxParallelProcessedMsgs=1 leads to the usage of a QueueingConsumer.

Parameters:

maxParallelProcessedMsgs - the number of messaegs that are processed in parallel

Method Detail

generateTask

public void generateTask(InputStream dataStream)

Description copied from class: AbstractStreamingTaskGenerator

Generates a task from the given data, sends it to the system, takes the timestamp of the moment at which the message has been sent to the system and sends it together with the expected response to the evaluation storage.

Specified by:

generateTask in class AbstractStreamingTaskGenerator

Parameters:

dataStream - stream containing incoming data generated by a data generator

receiveGeneratedData

public void receiveGeneratedData(byte[] data)

Description copied from interface: GeneratedDataReceivingComponent

This method is called if data is received from a data generator.

Specified by:

receiveGeneratedData in interface GeneratedDataReceivingComponent

Parameters:

data - the data received from a data generator

generateTask

protected abstract void generateTask(byte[] data)
                              throws Exception

Generates a task from the given data, sends it to the system, takes the timestamp of the moment at which the message has been sent to the system and sends it together with the expected response to the evaluation storage.

Parameters:

data - incoming data generated by a data generator

Throws:

Exception - if a sever error occurred

sendTaskToEvalStorage

protected void sendTaskToEvalStorage(String taskIdString,
                                     long timestamp,
                                     byte[] data)
                              throws IOException

This method sends the given data and the given timestamp of the task with the given task id to the evaluation storage.

Parameters:

taskIdString - the id of the task

timestamp - the timestamp of the moment in which the task has been sent to the system

data - the expected response for the task with the given id

Throws:

IOException - if there is an error during the sending

sendTaskToSystemAdapter

protected void sendTaskToSystemAdapter(String taskIdString,
                                       byte[] data)
                                throws IOException

Sends the given task with the given task id and data to the system.

Parameters:

taskIdString - the id of the task

data - the data of the task

Throws:

IOException - if there is an error during the sending