public class SystemMessageDelivery extends GraphStage<FlowShape<OutboundEnvelope,OutboundEnvelope>>
Modifier and Type | Class and Description |
---|---|
static class |
SystemMessageDelivery.Ack |
static class |
SystemMessageDelivery.Ack$ |
static interface |
SystemMessageDelivery.AckedDeliveryMessage |
static class |
SystemMessageDelivery.ClearSystemMessageDelivery$ |
static class |
SystemMessageDelivery.GaveUpSystemMessageException |
static class |
SystemMessageDelivery.Nack |
static class |
SystemMessageDelivery.Nack$ |
static class |
SystemMessageDelivery.SystemMessageEnvelope |
static class |
SystemMessageDelivery.SystemMessageEnvelope$ |
Constructor and Description |
---|
SystemMessageDelivery(OutboundContext outboundContext,
ActorRef deadLetters,
scala.concurrent.duration.FiniteDuration resendInterval,
int maxBufferSize) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
static scala.Tuple2<GraphStageLogic,NotUsed> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Inlet<OutboundEnvelope> |
in() |
protected static Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<OutboundEnvelope> |
out() |
FlowShape<OutboundEnvelope,OutboundEnvelope> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
static Graph<S,M> |
withAttributes(Attributes attr) |
createLogicAndMaterializedValue
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public SystemMessageDelivery(OutboundContext outboundContext, ActorRef deadLetters, scala.concurrent.duration.FiniteDuration resendInterval, int maxBufferSize)
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
protected static Attributes initialAttributes()
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)
public Inlet<OutboundEnvelope> in()
public Outlet<OutboundEnvelope> out()
public FlowShape<OutboundEnvelope,OutboundEnvelope> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<FlowShape<OutboundEnvelope,OutboundEnvelope>>