cloud.orbit.actors.runtime

Class AbstractExecution

java.lang.Object

cloud.orbit.actors.net.HandlerAdapter

cloud.orbit.actors.runtime.AbstractExecution

All Implemented Interfaces:

Handler

Direct Known Subclasses:

Execution

public abstract class AbstractExecution
extends HandlerAdapter

Field Summary

Fields

Modifier and Type	Field and Description
protected MultiExecutionSerializer<Object>	executionSerializer
protected org.slf4j.Logger	logger
protected int	maxQueueSize
protected LongAdder	messagesHandled
protected LongAdder	messagesReceived
protected LongAdder	refusedExecutions

Constructor Summary

Constructors

Constructor and Description
AbstractExecution()

Method Summary

Modifier and Type	Method and Description
abstract Task<Void>	cleanup()
void	setExecutionSerializer(MultiExecutionSerializer<Object> executionSerializer)

Methods inherited from class cloud.orbit.actors.net.HandlerAdapter

close, connect, disconnect, onActive, onEventTriggered, onExceptionCaught, onInactive, onRead, onRegistered, write

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.slf4j.Logger logger

executionSerializer

protected MultiExecutionSerializer<Object> executionSerializer

maxQueueSize

protected int maxQueueSize

messagesReceived

protected final LongAdder messagesReceived

messagesHandled

protected final LongAdder messagesHandled

refusedExecutions

protected final LongAdder refusedExecutions

Constructor Detail

AbstractExecution

public AbstractExecution()

Method Detail

cleanup

public abstract Task<Void> cleanup()

setExecutionSerializer

public void setExecutionSerializer(MultiExecutionSerializer<Object> executionSerializer)