public abstract class ActorPublisherMessage extends java.lang.Object implements DeadLetterSuppression
Modifier and Type | Class and Description |
---|---|
static class |
ActorPublisherMessage.Cancel |
static class |
ActorPublisherMessage.Cancel$
This message is delivered to the
ActorPublisher actor when the stream subscriber cancels the
subscription. |
static class |
ActorPublisherMessage.Request
This message is delivered to the
ActorPublisher actor when the stream subscriber requests
more elements. |
static class |
ActorPublisherMessage.Request$ |
static class |
ActorPublisherMessage.SubscriptionTimeoutExceeded |
static class |
ActorPublisherMessage.SubscriptionTimeoutExceeded$
This message is delivered to the
ActorPublisher actor in order to signal the exceeding of an subscription timeout. |
Constructor and Description |
---|
ActorPublisherMessage() |
Modifier and Type | Method and Description |
---|---|
static ActorPublisherMessage.Cancel$ |
cancelInstance()
Java API: get the singleton instance of the
Cancel message |
static ActorPublisherMessage.SubscriptionTimeoutExceeded$ |
subscriptionTimeoutExceededInstance()
Java API: get the singleton instance of the
SubscriptionTimeoutExceeded message |
public static ActorPublisherMessage.Cancel$ cancelInstance()
Cancel
messagepublic static ActorPublisherMessage.SubscriptionTimeoutExceeded$ subscriptionTimeoutExceededInstance()
SubscriptionTimeoutExceeded
message