org.hobbit.controller.test

Class RequestBenchmarkDetails

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.controller.test.RequestBenchmarkDetails

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
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 String	NEWLINE
private static long	REQUEST_TIMEOUT
static String	USER_NAME_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
RequestBenchmarkDetails()

Method Summary

Modifier and Type	Method and Description
void	close()
void	init()
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

USER_NAME_KEY

public static final String USER_NAME_KEY

See Also:

Constant Field Values

REQUEST_TIMEOUT

private static final long REQUEST_TIMEOUT

See Also:

Constant Field Values

NEWLINE

private static final String NEWLINE

frontEnd2Controller

protected com.rabbitmq.client.Channel frontEnd2Controller

consumer

protected com.rabbitmq.client.QueueingConsumer consumer

Constructor Detail

RequestBenchmarkDetails

public RequestBenchmarkDetails()

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

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