Class AmqpCreditBasedSender

  • All Implemented Interfaces:
    org.reactivestreams.Processor<Message<?>,​Message<?>>, org.reactivestreams.Publisher<Message<?>>, org.reactivestreams.Subscriber<Message<?>>, org.reactivestreams.Subscription

    public class AmqpCreditBasedSender
    extends Object
    implements org.reactivestreams.Processor<Message<?>,​Message<?>>, org.reactivestreams.Subscription
    • Method Detail

      • subscribe

        public void subscribe​(org.reactivestreams.Subscriber<? super Message<?>> subscriber)
        Specified by:
        subscribe in interface org.reactivestreams.Publisher<Message<?>>
      • isConnected

        @CheckReturnValue
        public io.smallrye.mutiny.Uni<Boolean> isConnected()
      • getHealthTimeout

        public int getHealthTimeout()
      • onSubscribe

        public void onSubscribe​(org.reactivestreams.Subscription subscription)
        Specified by:
        onSubscribe in interface org.reactivestreams.Subscriber<Message<?>>
      • onNext

        public void onNext​(Message<?> message)
        Specified by:
        onNext in interface org.reactivestreams.Subscriber<Message<?>>
      • onError

        public void onError​(Throwable throwable)
        Specified by:
        onError in interface org.reactivestreams.Subscriber<Message<?>>
      • onComplete

        public void onComplete()
        Specified by:
        onComplete in interface org.reactivestreams.Subscriber<Message<?>>
      • request

        public void request​(long l)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • cancel

        public void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription