org.dice_research.squirrel.rabbit

Class RPCServer

java.lang.Object

org.hobbit.core.rabbit.DataReceiverImpl

org.dice_research.squirrel.rabbit.RPCServer

All Implemented Interfaces:

Closeable, AutoCloseable, ResponseHandler, org.hobbit.core.rabbit.DataReceiver

public class RPCServer
extends org.hobbit.core.rabbit.DataReceiverImpl
implements ResponseHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RPCServer.Builder
protected class	RPCServer.MsgProcessingTask

Nested classes/interfaces inherited from class org.hobbit.core.rabbit.DataReceiverImpl

org.hobbit.core.rabbit.DataReceiverImpl.MsgReceivingTask

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOGGER
protected com.rabbitmq.client.Channel	responseChannel

Fields inherited from class org.hobbit.core.rabbit.DataReceiverImpl

queue

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RPCServer(org.hobbit.core.data.RabbitQueue queue, RespondingDataHandler handler, int maxParallelProcessedMsgs, com.rabbitmq.client.Channel responseChannel)

Method Summary

Modifier and Type	Method and Description
static RPCServer.Builder	builder() Returns a newly created RPCServer.Builder.
protected Runnable	buildMsgProcessingTask(com.rabbitmq.client.QueueingConsumer.Delivery delivery)
void	sendResponse(byte[] data, String responseQueueName, String correlId)

Methods inherited from class org.hobbit.core.rabbit.DataReceiverImpl

buildMsgReceivingTask, close, closeWhenFinished, getDataHandler, getErrorCount, getExecutor, getQueue, increaseErrorCount

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

responseChannel

protected com.rabbitmq.client.Channel responseChannel

Constructor Detail

RPCServer

protected RPCServer(org.hobbit.core.data.RabbitQueue queue,
                    RespondingDataHandler handler,
                    int maxParallelProcessedMsgs,
                    com.rabbitmq.client.Channel responseChannel)
             throws IOException

Throws:

IOException

Method Detail

builder

public static RPCServer.Builder builder()

Returns a newly created RPCServer.Builder.

Returns:

a new RPCServer.Builder instance

sendResponse

public void sendResponse(byte[] data,
                         String responseQueueName,
                         String correlId)

Specified by:

sendResponse in interface ResponseHandler

buildMsgProcessingTask

protected Runnable buildMsgProcessingTask(com.rabbitmq.client.QueueingConsumer.Delivery delivery)

Overrides:

buildMsgProcessingTask in class org.hobbit.core.rabbit.DataReceiverImpl