Class ConsumerController.Delivery<A>

  • Enclosing class:
    ConsumerController

    public static final class ConsumerController.Delivery<A>
    extends java.lang.Object
    Received messages from the producer are wrapped in Delivery when sent to the consumer. When the message has been processed the consumer is supposed to send ConsumerController.Confirmed back to the ConsumerController via the confirmTo.
    • Method Detail

      • message

        public A message()
      • producerId

        public java.lang.String producerId()
      • seqNr

        public long seqNr()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object