org.hobbit.controller.test

Class RequestSystemResources

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.hobbit.core.components.AbstractCommandReceivingComponent

org.hobbit.core.components.AbstractPlatformConnectorComponent

org.hobbit.controller.test.RequestSystemResources

All Implemented Interfaces:

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

public class RequestSystemResources
extends org.hobbit.core.components.AbstractPlatformConnectorComponent

Field Summary

Fields

Modifier and Type	Field and Description
private static String	cmdLineHobbitId
protected com.rabbitmq.client.QueueingConsumer	consumer
private static org.slf4j.Logger	LOGGER
protected org.hobbit.core.components.utils.SystemResourceUsageRequester	resUsageRequester

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

Method Summary

Modifier and Type	Method and Description
void	close()
void	init()
static void	main(String[] args)
void	receiveCommand(byte command, byte[] data)
void	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

LOGGER

private static final org.slf4j.Logger LOGGER

cmdLineHobbitId

private static String cmdLineHobbitId

resUsageRequester

protected org.hobbit.core.components.utils.SystemResourceUsageRequester resUsageRequester

consumer

protected com.rabbitmq.client.QueueingConsumer consumer

Constructor Detail

RequestSystemResources

public RequestSystemResources()

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)

Specified by:

receiveCommand in interface org.hobbit.core.components.CommandReceivingComponent

Overrides:

receiveCommand in class org.hobbit.core.components.AbstractPlatformConnectorComponent

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

main

public static void main(String[] args)