org.hobbit.controller.front

Class FrontEndApiHandler

java.lang.Object

org.hobbit.core.rabbit.DataReceiverImpl

org.hobbit.controller.front.FrontEndApiHandler

All Implemented Interfaces:

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

public class FrontEndApiHandler
extends org.hobbit.core.rabbit.DataReceiverImpl

This class implements a RabbitMQ DefaultConsumer and handles request that are coming from the front end.

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FrontEndApiHandler.Builder
protected class	FrontEndApiHandler.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 PlatformController	controller
private static int	DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES
private static org.slf4j.Logger	LOGGER

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

queue

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FrontEndApiHandler(org.hobbit.core.data.RabbitQueue queue, PlatformController controller, int maxParallelProcessedMsgs)

Method Summary

Modifier and Type	Method and Description
protected Runnable	buildMsgProcessingTask(com.rabbitmq.client.QueueingConsumer.Delivery delivery)

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

builder, 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

DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

private static final int DEFAULT_MAX_PARALLEL_PROCESSED_MESSAGES

See Also:

Constant Field Values

controller

private final PlatformController controller

Constructor Detail

FrontEndApiHandler

protected FrontEndApiHandler(org.hobbit.core.data.RabbitQueue queue,
                             PlatformController controller,
                             int maxParallelProcessedMsgs)
                      throws IOException

Throws:

IOException

Method Detail

buildMsgProcessingTask

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

Overrides:

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