Package io.smallrye.reactive.messaging.amqp

Class AmqpCreditBasedSender

java.lang.Object

io.smallrye.reactive.messaging.amqp.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

Constructor Summary

Constructors

Constructor	Description
AmqpCreditBasedSender(AmqpConnector connector, ConnectionHolder holder, AmqpConnectorOutgoingConfiguration configuration, io.smallrye.mutiny.Uni<io.vertx.mutiny.amqp.AmqpSender> retrieveSender)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	onComplete()
void	onError(Throwable throwable)
void	onNext(Message<?> message)
void	onSubscribe(org.reactivestreams.Subscription subscription)
void	request(long l)
void	subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmqpCreditBasedSender

public AmqpCreditBasedSender(AmqpConnector connector,
                             ConnectionHolder holder,
                             AmqpConnectorOutgoingConfiguration configuration,
                             io.smallrye.mutiny.Uni<io.vertx.mutiny.amqp.AmqpSender> retrieveSender)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<Message<?>>

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