org.hobbit.core.components.test

Class InMemoryEvaluationStore

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.core.components.AbstractEvaluationStorage

org.hobbit.core.components.test.InMemoryEvaluationStore

All Implemented Interfaces:

Closeable, AutoCloseable, CommandReceivingComponent, Component, ExpectedResponseReceivingComponent, PlatformConnector, ResponseReceivingComponent

public class InMemoryEvaluationStore
extends AbstractEvaluationStorage

Simple in-memory implementation of an evaluation storage that can be used for testing purposes.

Author:

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InMemoryEvaluationStore.ResultPairImpl A simple structure implementing the ResultPair interface.

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

AbstractEvaluationStorage.ExpectedResponseReceiver, AbstractEvaluationStorage.IterationRequestReceiver, AbstractEvaluationStorage.SystemResponseReceiver

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,ResultPair>	results Map containing a mapping from task Ids to result pairs.

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

ackChannel, ackExchangeName, evalModule2EvalStoreQueue, EXPECTED_RESPONSE_STREAM_ID, expResponseReceiver, ITERATOR_ID_STREAM_ID, NEW_ITERATOR_ID, RECEIVE_TIMESTAMP_FOR_SYSTEM_RESULTS_KEY, RECEIVED_RESPONSE_STREAM_ID, receiveTimeStamp, replyingSenders, resultPairIterators, systemResponseReceiver, systemResultReceiver, taskResultReceiver

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
InMemoryEvaluationStore()

Method Summary

Modifier and Type	Method and Description
protected Iterator<ResultPair>	createIterator() Creates a new iterator that iterates over the response pairs.
void	putResult(boolean isExpectedResult, String taskId, long timestamp, byte[] data) Adds the given result to the map of results.
static byte[]	putTimestampInFront(long timestamp, byte[] data) Copies timestamp and data in one single byte array starting with the timestamp.
void	receiveExpectedResponseData(String taskId, long timestamp, InputStream stream) This method is called if an expected response is received from a task generator component.
void	receiveResponseData(String taskId, long timestamp, InputStream stream) This method is called if a response is received from the system.

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

acknowledgeResponse, close, init, receiveCommand, run

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

Field Detail

results

private Map<String,ResultPair> results

Map containing a mapping from task Ids to result pairs.

Constructor Detail

InMemoryEvaluationStore

public InMemoryEvaluationStore()

Method Detail

receiveResponseData

public void receiveResponseData(String taskId,
                                long timestamp,
                                InputStream stream)

Description copied from interface: ResponseReceivingComponent

This method is called if a response is received from the system.

Parameters:

taskId - the id of the task

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

stream - the data received from a data generator

receiveExpectedResponseData

public void receiveExpectedResponseData(String taskId,
                                        long timestamp,
                                        InputStream stream)

Description copied from interface: ExpectedResponseReceivingComponent

This method is called if an expected response is received from a task generator component.

Parameters:

taskId - the id of the task

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

putResult

public void putResult(boolean isExpectedResult,
                      String taskId,
                      long timestamp,
                      byte[] data)

Adds the given result to the map of results.

Parameters:

isExpectedResult - true if the result has been received from a task generator, i.e., is the expected result for a task

taskId - id of the task

timestamp - time stamp for the task result

data - the result

createIterator

protected Iterator<ResultPair> createIterator()

Description copied from class: AbstractEvaluationStorage

Creates a new iterator that iterates over the response pairs.

Specified by:

createIterator in class AbstractEvaluationStorage

Returns:

a new iterator or null if an error occurred

putTimestampInFront

public static byte[] putTimestampInFront(long timestamp,
                                         byte[] data)

Copies timestamp and data in one single byte array starting with the timestamp.

Parameters:

timestamp - a timestamp that belongs to the given data

data -

Returns:

a single array containing both