Uses of Class
io.vertx.reactivex.core.eventbus.MessageProducer

Packages that use MessageProducer

Package	Description
io.vertx.reactivex.amqpbridge
io.vertx.reactivex.core.eventbus

Uses of MessageProducer in io.vertx.reactivex.amqpbridge

Methods in io.vertx.reactivex.amqpbridge that return MessageProducer

Modifier and Type	Method and Description
<T> MessageProducer<T>	AmqpBridge.createProducer(String amqpAddress) Creates a producer to the given AMQP address.

Uses of MessageProducer in io.vertx.reactivex.core.eventbus

Fields in io.vertx.reactivex.core.eventbus with type parameters of type MessageProducer

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<MessageProducer>	MessageProducer.__TYPE_ARG

Methods in io.vertx.reactivex.core.eventbus that return MessageProducer

Modifier and Type	Method and Description
MessageProducer<T>	MessageProducer.deliveryOptions(DeliveryOptions options) Update the delivery options of this producer.
MessageProducer<T>	MessageProducer.drainHandler(Handler<Void> handler)
MessageProducer<T>	MessageProducer.exceptionHandler(Handler<Throwable> handler)
static <T> MessageProducer<T>	MessageProducer.newInstance(MessageProducer arg)
static <T> MessageProducer<T>	MessageProducer.newInstance(MessageProducer arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)
<T> MessageProducer<T>	EventBus.publisher(String address) Create a message publisher against the specified address.
<T> MessageProducer<T>	EventBus.publisher(String address, DeliveryOptions options) Like EventBus.publisher(java.lang.String) but specifying delivery options that will be used for configuring the delivery of the message.
MessageProducer<T>	MessageProducer.send(T message) Deprecated.
<R> MessageProducer<T>	MessageProducer.send(T message, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated.
<T> MessageProducer<T>	EventBus.sender(String address) Create a message sender against the specified address.
<T> MessageProducer<T>	EventBus.sender(String address, DeliveryOptions options) Like EventBus.sender(java.lang.String) but specifying delivery options that will be used for configuring the delivery of the message.
MessageProducer<T>	MessageProducer.setWriteQueueMaxSize(int maxSize)
MessageProducer<T>	MessageProducer.write(T data)
MessageProducer<T>	MessageProducer.write(T data, Handler<AsyncResult<Void>> handler)