Package org.eclipse.ditto.services.gateway.streaming.actors

Class CommandSubscriber

  • All Implemented Interfaces:
    akka.actor.Actor, akka.stream.actor.ActorSubscriber
    public final class CommandSubscriber
extends akka.stream.actor.AbstractActorSubscriber
    Actor handling Commands by forwarding it to an passed in delegateActor applying backpressure.

    Backpressure can be and is only applied for commands requiring a response: DittoHeaders.isResponseRequired().

    • Nested Class Summary

      • Nested classes/interfaces inherited from class akka.actor.AbstractActor

        akka.actor.AbstractActor.ActorContext, akka.actor.AbstractActor.Receive

      • Nested classes/interfaces inherited from interface akka.actor.Actor

        akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

      • Nested classes/interfaces inherited from interface akka.stream.actor.ActorSubscriber

        akka.stream.actor.ActorSubscriber.OnSubscribe, akka.stream.actor.ActorSubscriber.OnSubscribe$

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      akka.actor.AbstractActor.Receive createReceive()  
      static akka.actor.Props props​(akka.actor.ActorRef delegateActor, int backpressureQueueSize, akka.event.EventStream eventStream)
      Creates Akka configuration object Props for this CommandSubscriber.
      akka.stream.actor.RequestStrategy requestStrategy()  

      • Methods inherited from class akka.stream.actor.AbstractActorSubscriber

        akka$stream$actor$ActorSubscriber$_setter_$akka$stream$actor$ActorSubscriber$$state_$eq, akka$stream$actor$ActorSubscriber$$_canceled, akka$stream$actor$ActorSubscriber$$_canceled_$eq, akka$stream$actor$ActorSubscriber$$requested, akka$stream$actor$ActorSubscriber$$requested_$eq, akka$stream$actor$ActorSubscriber$$state, akka$stream$actor$ActorSubscriber$$subscription, akka$stream$actor$ActorSubscriber$$subscription_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancel, canceled, create, remainingRequested, request

      • Methods inherited from class akka.actor.AbstractActor

        akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, emptyBehavior, getContext, getSelf, getSender, postRestart, postStop, preRestart, preRestart, preStart, receive, receiveBuilder, self, sender, supervisorStrategy, unhandled

      • Methods inherited from interface akka.actor.Actor

        akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

    • Method Detail

      • props

        public static akka.actor.Props props​(akka.actor.ActorRef delegateActor,
                                     int backpressureQueueSize,
                                     akka.event.EventStream eventStream)
        Creates Akka configuration object Props for this CommandSubscriber.
        Parameters:
        delegateActor - the ActorRef of the Actor to which to forward Commands.
        backpressureQueueSize - the max queue size of how many inflight commands a single producer can have.
        eventStream - used to subscribe to ResponsePublished events
        Returns:
        the Akka configuration Props object.

      • createReceive

        public akka.actor.AbstractActor.Receive createReceive()
        Specified by:
        createReceive in class akka.actor.AbstractActor

      • requestStrategy

        public akka.stream.actor.RequestStrategy requestStrategy()