com.hotels.styx.common

Class QueueDrainingEventProcessor<S>

java.lang.Object

com.hotels.styx.common.AbstractEventProcessor<S>

com.hotels.styx.common.QueueDrainingEventProcessor<S>

Type Parameters:

S - state type

All Implemented Interfaces:

EventProcessor

public class QueueDrainingEventProcessor<S>
extends AbstractEventProcessor<S>

An event processor that is implemented using Queue Drain approach.

Constructor Summary

Constructors

Constructor and Description
QueueDrainingEventProcessor(StateMachine<S> stateMachine, BiConsumer<Throwable,S> errorHandler, String loggingPrefix) Constructs a new instance.

Method Summary

Methods inherited from class com.hotels.styx.common.AbstractEventProcessor

submit

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueDrainingEventProcessor

public QueueDrainingEventProcessor(StateMachine<S> stateMachine,
                                   BiConsumer<Throwable,S> errorHandler,
                                   String loggingPrefix)

Constructs a new instance.

Parameters:

stateMachine - state machine

errorHandler - handler to use if an exception/error is thrown by the state machine (e.g. during a transition side-effect)

loggingPrefix - a prefix to prepend to the beginning of log lines