Uses of Interface
io.vertx.core.eventbus.MessageProducer

Packages that use MessageProducer

Package	Description
io.vertx.core.eventbus
io.vertx.core.eventbus.impl
io.vertx.reactivex.core.eventbus
io.vertx.rxjava.core.eventbus

Uses of MessageProducer in io.vertx.core.eventbus

Methods in io.vertx.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)
<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(String) but specifying delivery options that will be used for configuring the delivery of the message.
MessageProducer<T>	MessageProducer.send(T message) Deprecated. instead use write(T) with a producer obtained from EventBus.sender(java.lang.String)
<R> MessageProducer<T>	MessageProducer.send(T message, Handler<AsyncResult<Message<R>>> replyHandler) Deprecated. instead use EventBus.request(String, Object, Handler)
<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(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)

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

Classes in io.vertx.core.eventbus.impl that implement MessageProducer

Modifier and Type	Class and Description
class	MessageProducerImpl<T>

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

Modifier and Type	Method and Description
MessageProducer<T>	MessageProducerImpl.deliveryOptions(DeliveryOptions options)
MessageProducer<T>	MessageProducerImpl.drainHandler(Handler<Void> handler)
MessageProducer<T>	MessageProducerImpl.exceptionHandler(Handler<Throwable> handler)
<T> MessageProducer<T>	EventBusImpl.publisher(String address)
<T> MessageProducer<T>	EventBusImpl.publisher(String address, DeliveryOptions options)
MessageProducer<T>	MessageProducerImpl.send(T message)
<R> MessageProducer<T>	MessageProducerImpl.send(T message, Handler<AsyncResult<Message<R>>> replyHandler)
<T> MessageProducer<T>	EventBusImpl.sender(String address)
<T> MessageProducer<T>	EventBusImpl.sender(String address, DeliveryOptions options)
MessageProducer<T>	MessageProducerImpl.setWriteQueueMaxSize(int s)
MessageProducer<T>	MessageProducerImpl.write(T data)
MessageProducer<T>	MessageProducerImpl.write(T data, Handler<AsyncResult<Void>> handler)

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

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

Modifier and Type	Method and Description
MessageProducer	MessageProducer.getDelegate()

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

Modifier and Type	Method and Description
static <T> MessageProducer<T>	MessageProducer.newInstance(MessageProducer arg)
static <T> MessageProducer<T>	MessageProducer.newInstance(MessageProducer arg, TypeArg<T> __typeArg_T)

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

Constructor and Description
MessageProducer(MessageProducer delegate)

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

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

Modifier and Type	Method and Description
MessageProducer	MessageProducer.getDelegate()

Methods in io.vertx.rxjava.core.eventbus with parameters of type MessageProducer

Modifier and Type	Method and Description
static <T> MessageProducer<T>	MessageProducer.newInstance(MessageProducer arg)
static <T> MessageProducer<T>	MessageProducer.newInstance(MessageProducer arg, TypeArg<T> __typeArg_T)

Constructors in io.vertx.rxjava.core.eventbus with parameters of type MessageProducer

Constructor and Description
MessageProducer(MessageProducer delegate)