Package akka.stream.actor
Class ActorPublisherMessage
- java.lang.Object
-
- akka.stream.actor.ActorPublisherMessage
-
- All Implemented Interfaces:
DeadLetterSuppression
- Direct Known Subclasses:
ActorPublisherMessage.Cancel
,ActorPublisherMessage.Request
,ActorPublisherMessage.SubscriptionTimeoutExceeded
public abstract class ActorPublisherMessage extends java.lang.Object implements DeadLetterSuppression
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ActorPublisherMessage.Cancel
static class
ActorPublisherMessage.Cancel$
static class
ActorPublisherMessage.Request
static class
ActorPublisherMessage.Request$
static class
ActorPublisherMessage.SubscriptionTimeoutExceeded
static class
ActorPublisherMessage.SubscriptionTimeoutExceeded$
This message is delivered to theActorPublisher
actor in order to signal the exceeding of an subscription timeout.
-
Constructor Summary
Constructors Constructor Description ActorPublisherMessage()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static ActorPublisherMessage.Cancel$
cancelInstance()
static ActorPublisherMessage.SubscriptionTimeoutExceeded$
subscriptionTimeoutExceededInstance()
-
-
-
Method Detail
-
cancelInstance
public static ActorPublisherMessage.Cancel$ cancelInstance()
-
subscriptionTimeoutExceededInstance
public static ActorPublisherMessage.SubscriptionTimeoutExceeded$ subscriptionTimeoutExceededInstance()
-
-