org.hobbit.core.components

Class AbstractSystemAdapter

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.stream.AbstractStreamingSystemAdapter

org.hobbit.core.components.AbstractSystemAdapter

All Implemented Interfaces:

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

public abstract class AbstractSystemAdapter
extends AbstractStreamingSystemAdapter
implements GeneratedDataReceivingComponent, TaskReceivingComponent

This abstract class implements basic functions that can be used to implement a system adapter.

Author:

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

Nested Class Summary

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

AbstractStreamingSystemAdapter.GeneratedDataHandler, AbstractStreamingSystemAdapter.GeneratedTaskHandler

Field Summary

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

dataReceiver, sender2EvalStore, systemParamModel, taskReceiver

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
AbstractSystemAdapter()
AbstractSystemAdapter(DataSender sender2EvalStore, DataReceiver dataReceiver, DataReceiver taskReceiver)
AbstractSystemAdapter(int maxParallelProcessedMsgs)

Method Summary

Modifier and Type	Method and Description
void	receiveGeneratedData(InputStream dataStream) This method is called if a new data stream is received from a data generator.
void	receiveGeneratedTask(String taskId, InputStream dataStream) This method is called if a task is received from a task generator.
protected void	sendResultToEvalStorage(String taskIdString, byte[] data) This method sends the given result data for the task with the given task id to the evaluation storage.

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

close, init, receiveCommand, run, sendResultToEvalStorage, terminate

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.GeneratedDataReceivingComponent

receiveGeneratedData

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

receiveGeneratedTask

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

init, run

Methods inherited from interface java.io.Closeable

close

Constructor Detail

AbstractSystemAdapter

public AbstractSystemAdapter()

AbstractSystemAdapter

public AbstractSystemAdapter(int maxParallelProcessedMsgs)

AbstractSystemAdapter

public AbstractSystemAdapter(DataSender sender2EvalStore,
                             DataReceiver dataReceiver,
                             DataReceiver taskReceiver)

Method Detail

sendResultToEvalStorage

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

This method sends the given result data for the task with the given task id to the evaluation storage.

Parameters:

taskIdString - the id of the task

data - the data of the task

Throws:

IOException - if there is an error during the sending

receiveGeneratedData

public void receiveGeneratedData(InputStream dataStream)

Description copied from interface: StreamingGeneratedDataReceivingComponent

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

Specified by:

receiveGeneratedData in interface StreamingGeneratedDataReceivingComponent

Parameters:

dataStream - the stream from which the data received from a data generator is read

receiveGeneratedTask

public void receiveGeneratedTask(String taskId,
                                 InputStream dataStream)

Description copied from interface: StreamingTaskReceivingComponent

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

Specified by:

receiveGeneratedTask in interface StreamingTaskReceivingComponent

Parameters:

taskId - the id of the received task

dataStream - the data received from a data generator