Package org.eclipse.ditto.services.utils.akka.streaming

Class StreamConstants

java.lang.Object

org.eclipse.ditto.services.utils.akka.streaming.StreamConstants

public final class StreamConstants
extends Object

Constants used for streaming utils.

Field Summary

Fields

Modifier and Type	Field	Description
static Object	DOES_NOT_HAVE_NEXT_MSG	Message received by stream forwarder to signal that all messages for a stream element have been sent.
static Object	FORWARDER_EXCEEDED_MAX_IDLE_TIME_MSG	Message which signals the forwarder stayed idle for too long.
static Object	STREAM_ACK_MSG	Ack message from AbstractStreamForwarder to AbstractStreamingActor for back-pressure.
static Object	STREAM_COMPLETED	Message which signals that a stream has been successfully finished.
static Object	STREAM_FAILED	Message to signal upstream failure.
static Object	STREAM_STARTED	Message which signals that a stream is started.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

STREAM_COMPLETED

public static final Object STREAM_COMPLETED

Message which signals that a stream has been successfully finished.

STREAM_STARTED

public static final Object STREAM_STARTED

Message which signals that a stream is started.

STREAM_ACK_MSG

public static final Object STREAM_ACK_MSG

Ack message from AbstractStreamForwarder to AbstractStreamingActor for back-pressure.

STREAM_FAILED

public static final Object STREAM_FAILED

Message to signal upstream failure.

DOES_NOT_HAVE_NEXT_MSG

public static final Object DOES_NOT_HAVE_NEXT_MSG

Message received by stream forwarder to signal that all messages for a stream element have been sent.

FORWARDER_EXCEEDED_MAX_IDLE_TIME_MSG

public static final Object FORWARDER_EXCEEDED_MAX_IDLE_TIME_MSG

Message which signals the forwarder stayed idle for too long.