org.hobbit.core.components

Class AbstractEvaluationModule

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.stream.AbstractStreamingEvaluationModule

org.hobbit.core.components.AbstractEvaluationModule

All Implemented Interfaces:

Closeable, AutoCloseable, CommandReceivingComponent, Component, PlatformConnector, IncomingStreamHandler, PairedStreamHandler

public abstract class AbstractEvaluationModule
extends AbstractStreamingEvaluationModule

This abstract class implements basic functions that can be used to implement a task generator.

Author:

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

Field Summary

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

evalModule2EvalStoreQueue, experimentUri, iterationFinished, iteratorId, receiver, requestNextResultPair

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

cmdChannel, cmdQueueFactory, cmdResponseTimeout, 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
AbstractEvaluationModule()

Method Summary

Modifier and Type	Method and Description
protected abstract void	evaluateResponse(byte[] expectedData, byte[] receivedData, long taskSentTimestamp, long responseReceivedTimestamp) Evaluates the given response pair.
protected void	evaluateResponse(InputStream expectedData, InputStream receivedData, long taskSentTimestamp, long responseReceivedTimestamp) Evaluates the given response pair.

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

close, collectResponses, createDefaultModel, handleIncomingStream, handleIncomingStreams, init, receiveCommand, run, summarizeEvaluation

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, getCmdResponseTimeout, handleCmd, sendToCmdQueue, sendToCmdQueue, sendToCmdQueue, setCmdResponseTimeout

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

Constructor Detail

AbstractEvaluationModule

public AbstractEvaluationModule()

Method Detail

evaluateResponse

protected void evaluateResponse(InputStream expectedData,
                                InputStream receivedData,
                                long taskSentTimestamp,
                                long responseReceivedTimestamp)
                         throws Exception

Description copied from class: AbstractStreamingEvaluationModule

Evaluates the given response pair.

Specified by:

evaluateResponse in class AbstractStreamingEvaluationModule

Parameters:

expectedData - the data that has been expected

receivedData - the data that has been received from the system

taskSentTimestamp - the time at which the task has been sent to the system

responseReceivedTimestamp - the time at which the response has been received from the system

Throws:

Exception - if an error occurs during the evaluation

evaluateResponse

protected abstract void evaluateResponse(byte[] expectedData,
                                         byte[] receivedData,
                                         long taskSentTimestamp,
                                         long responseReceivedTimestamp)
                                  throws Exception

Evaluates the given response pair.

Parameters:

expectedData - the data that has been expected

receivedData - the data that has been received from the system

taskSentTimestamp - the time at which the task has been sent to the system

responseReceivedTimestamp - the time at which the response has been received from the system

Throws:

Exception - if an error occurs during the evaluation