org.hobbit.controller.test

Class StartBenchmarkRequest

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.controller.test.StartBenchmarkRequest

All Implemented Interfaces:

Closeable, AutoCloseable, org.hobbit.core.components.CommandReceivingComponent, org.hobbit.core.components.Component

public class StartBenchmarkRequest
extends org.hobbit.core.components.AbstractCommandReceivingComponent

Field Summary

Fields

Modifier and Type	Field and Description
static String	BENCHMARK_PARAM_FILE_KEY
static String	BENCHMARK_URI_KEY
protected com.rabbitmq.client.QueueingConsumer	consumer
protected com.rabbitmq.client.Channel	frontEnd2Controller
private static org.slf4j.Logger	LOGGER
private static long	REQUEST_TIMEOUT
static String	SYSTEM_URI_KEY

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

Method Summary

Modifier and Type	Method and Description
void	close()
void	init()
private static org.apache.jena.rdf.model.Model	readModel(String benchmarkModelFile)
void	receiveCommand(byte command, byte[] data)
void	run()

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

addCommandHeaderId, createContainer, createContainer, handleCmd, sendToCmdQueue, sendToCmdQueue, sendToCmdQueue, stopContainer

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

LOGGER

private static final org.slf4j.Logger LOGGER

BENCHMARK_URI_KEY

public static final String BENCHMARK_URI_KEY

See Also:

Constant Field Values

SYSTEM_URI_KEY

public static final String SYSTEM_URI_KEY

See Also:

Constant Field Values

BENCHMARK_PARAM_FILE_KEY

public static final String BENCHMARK_PARAM_FILE_KEY

See Also:

Constant Field Values

REQUEST_TIMEOUT

private static final long REQUEST_TIMEOUT

See Also:

Constant Field Values

frontEnd2Controller

protected com.rabbitmq.client.Channel frontEnd2Controller

consumer

protected com.rabbitmq.client.QueueingConsumer consumer

Constructor Detail

StartBenchmarkRequest

public StartBenchmarkRequest()

Method Detail

init

public void init()
          throws Exception

Specified by:

init in interface org.hobbit.core.components.Component

Overrides:

init in class org.hobbit.core.components.AbstractCommandReceivingComponent

Throws:

Exception

receiveCommand

public void receiveCommand(byte command,
                           byte[] data)

run

public void run()
         throws Exception

Throws:

Exception

readModel

private static org.apache.jena.rdf.model.Model readModel(String benchmarkModelFile)

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.hobbit.core.components.AbstractCommandReceivingComponent

Throws:

IOException