Class HobbitWrapper
java.lang.Object
org.hobbit.core.components.AbstractComponent
org.hobbit.core.components.AbstractCommandReceivingComponent
org.hobbit.core.components.AbstractPlatformConnectorComponent
org.hobbit.core.components.AbstractSystemAdapter
de.uni_mannheim.informatik.dws.melt.receiver_hobbit.HobbitWrapper
- All Implemented Interfaces:
Closeable
,AutoCloseable
,org.hobbit.core.components.CommandReceivingComponent
,org.hobbit.core.components.Component
,org.hobbit.core.components.GeneratedDataReceivingComponent
,org.hobbit.core.components.PlatformConnector
,org.hobbit.core.components.TaskReceivingComponent
public class HobbitWrapper
extends org.hobbit.core.components.AbstractSystemAdapter
Wraps the interface of HOBBIT platform and maps it to calls similar to SEALS.
-
Field Summary
Modifier and TypeFieldDescriptionprivate ExecutorService
private static final org.slf4j.Logger
private final Map<String,
FileReceiverCallableState> Fields inherited from class org.hobbit.core.components.AbstractSystemAdapter
dataGenReceiver, sender2EvalStore, systemParamModel, taskGenReceiver
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
-
Method Summary
Modifier and TypeMethodDescriptionvoid
init()
void
receiveGeneratedData
(byte[] data) void
receiveGeneratedTask
(String taskId, byte[] data) private File
runTool
(URI source, URI target, URL inputAlignment, Properties parameters) Methods inherited from class org.hobbit.core.components.AbstractSystemAdapter
close, 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, getCmdResponseTimeout, handleCmd, sendToCmdQueue, sendToCmdQueue, sendToCmdQueue, setCmdResponseTimeout
Methods inherited from class org.hobbit.core.components.AbstractComponent
createConnection, generateSessionQueueName, getHobbitSessionId
-
Field Details
-
LOGGER
private static final org.slf4j.Logger LOGGER -
executor
-
receivers
-
-
Constructor Details
-
HobbitWrapper
public HobbitWrapper()
-
-
Method Details
-
init
- Specified by:
init
in interfaceorg.hobbit.core.components.Component
- Overrides:
init
in classorg.hobbit.core.components.AbstractSystemAdapter
- Throws:
Exception
-
receiveGeneratedData
public void receiveGeneratedData(byte[] data) -
receiveGeneratedTask
-
runTool
-