org.dice_research.squirrel.components

Class WorkerComponentConfig

java.lang.Object

org.hobbit.core.components.AbstractComponent

org.dice_research.squirrel.components.WorkerComponentConfig

All Implemented Interfaces:

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

@Configuration
public class WorkerComponentConfig
extends org.hobbit.core.components.AbstractComponent

Field Summary

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

Method Summary

Modifier and Type	Method and Description
org.hobbit.core.rabbit.RabbitRpcClient	client()
void	run()
org.hobbit.core.rabbit.DataSender	sender()

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

close, createConnection, generateSessionQueueName, getHobbitSessionId, init

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerComponentConfig

public WorkerComponentConfig()
                      throws Exception

Throws:

Exception

Method Detail

sender

@Bean(name="sender")
public org.hobbit.core.rabbit.DataSender sender()
                                                              throws IllegalStateException,
                                                                     IOException

Throws:

IllegalStateException

IOException

client

@Bean(name="client")
public org.hobbit.core.rabbit.RabbitRpcClient client()
                                                                   throws IOException

Throws:

IOException

run

public void run()
         throws Exception

Throws:

Exception