Class ConsumerController.SequencedMessage$

  • All Implemented Interfaces:
    java.io.Serializable
    Enclosing class:
    ConsumerController

    public static class ConsumerController.SequencedMessage$
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Constructor Detail

      • SequencedMessage$

        public SequencedMessage$()
    • Method Detail

      • apply

        public <A> ConsumerController.SequencedMessage<A> apply​(java.lang.String producerId,
                                                                long seqNr,
                                                                java.lang.Object message,
                                                                boolean first,
                                                                boolean ack,
                                                                ActorRef<ProducerControllerImpl.InternalCommand> producerController)
        This is used between the ProducerController and ConsumerController. Should rarely be used in application code but is public because it's in the signature for the EntityTypeKey when using ShardingConsumerController.

        In the future we may also make the custom send in ProducerController public to make it possible to wrap it or send it in other ways when building higher level abstractions that are using the ProducerController. That is used by ShardingProducerController.

        Parameters:
        producerController - INTERNAL API: construction of SequencedMessage is internal
      • unapply

        public <A> scala.Option<scala.Tuple5<java.lang.String,​java.lang.Object,​java.lang.Object,​java.lang.Object,​java.lang.Object>> unapply​(ConsumerController.SequencedMessage<A> x$0)