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

Packages that use MessageProducer

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

Uses of MessageProducer in io.vertx.amqpbridge

Methods in io.vertx.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.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.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, io.vertx.lang.rx.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, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

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

Constructor and Description
MessageProducer(MessageProducer delegate)