org.hobbit.controller.test

Class RequestBenchmarks

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.controller.test.RequestBenchmarks

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field and Description
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

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

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

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

RequestBenchmarks

public RequestBenchmarks()

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