Vert.x 4.5.13 · io.vertx.core.eventbus.impl.MessageProducerImpl

Modifier and Type	Field and Description
private final String	address
private final EventBusImpl	bus
private final boolean	localOnly
private DeliveryOptions	options
private final boolean	send
private final Vertx	vertx

Access	Constructor and Description
public	MessageProducerImpl(Vertx vertx, String address, boolean send, DeliveryOptions options)

Method Summary

Modifier and Type	Method and Description
public String	address() Implements io.vertx.core.eventbus.MessageProducer.address.
public Future<Void>	close() Implements io.vertx.core.eventbus.MessageProducer.close. Closes the producer, this method should be called when the message producer is not used anymore.
public void	close(Handler<AsyncResult<Void>> handler) Implements io.vertx.core.eventbus.MessageProducer.close. Same as `close()` but with an `handler` called when the operation completes
public synchronized MessageProducer<T>	deliveryOptions(DeliveryOptions the new options options) Implements io.vertx.core.eventbus.MessageProducer.deliveryOptions. Update the delivery options of this producer.
public Future<Void>	write(T body) Implements io.vertx.core.eventbus.MessageProducer.write. Like `write(Object, Handler)` but returns a `Future` of the asynchronous result
public void	write(T the message body body, Handler<AsyncResult<Void>> handler) Implements io.vertx.core.eventbus.MessageProducer.write. Write a message to the event-bus, either sending or publishing.
private void	write(T data, Promise<Void> handler)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

address	back to summary
private final String address

bus	back to summary
private final EventBusImpl bus

localOnly	back to summary
private final boolean localOnly

options	back to summary
private DeliveryOptions options

send	back to summary
private final boolean send

vertx	back to summary
private final Vertx vertx

MessageProducerImpl	back to summary
public MessageProducerImpl(Vertx vertx, String address, boolean send, DeliveryOptions options)

Method Detail

address	back to summary
public String address() Implements io.vertx.core.eventbus.MessageProducer.address. Returns:String Doc from io.vertx.core.eventbus.MessageProducer.address. The address to which the producer produces messages. Annotations @Override

address

back to summary

public String address()

Implements io.vertx.core.eventbus.MessageProducer.address.

Returns:String

Doc from io.vertx.core.eventbus.MessageProducer.address.

The address to which the producer produces messages.

Annotations

@Override

close	back to summary
public Future<Void> close() Implements io.vertx.core.eventbus.MessageProducer.close. Doc from io.vertx.core.eventbus.MessageProducer.close. Closes the producer, this method should be called when the message producer is not used anymore. Returns:Future<Void> a future completed with the result Annotations @Override

back to summary

public Future<Void> close()

Implements io.vertx.core.eventbus.MessageProducer.close.

Doc from io.vertx.core.eventbus.MessageProducer.close.

Closes the producer, this method should be called when the message producer is not used anymore.

Returns:Future<Void>

a future completed with the result

Annotations

@Override

close back to summary

close	back to summary
public void close(Handler<AsyncResult<Void>> handler) Implements io.vertx.core.eventbus.MessageProducer.close. Doc from io.vertx.core.eventbus.MessageProducer.close. Same as `close()` but with an `handler` called when the operation completes Annotations @Override

public void close(Handler<AsyncResult<Void>> handler)

Implements io.vertx.core.eventbus.MessageProducer.close.

Doc from io.vertx.core.eventbus.MessageProducer.close.

Same as close() but with an handler called when the operation completes

Annotations

@Override

deliveryOptions	back to summary
public synchronized MessageProducer<T> deliveryOptions(DeliveryOptions options) Implements io.vertx.core.eventbus.MessageProducer.deliveryOptions. Doc from io.vertx.core.eventbus.MessageProducer.deliveryOptions. Update the delivery options of this producer. Parameters options:DeliveryOptions the new options Returns:MessageProducer<T> this producer object Annotations @Override

deliveryOptions

back to summary

public synchronized MessageProducer<T> deliveryOptions(DeliveryOptions options)

Implements io.vertx.core.eventbus.MessageProducer.deliveryOptions.

Doc from io.vertx.core.eventbus.MessageProducer.deliveryOptions.

Update the delivery options of this producer.

Parameters

options:DeliveryOptions: the new options

Returns:MessageProducer<T>

this producer object

Annotations

@Override

write back to summary

write	back to summary
public Future<Void> write(T body) Implements io.vertx.core.eventbus.MessageProducer.write. Doc from io.vertx.core.eventbus.MessageProducer.write. Like `write(Object, Handler)` but returns a `Future` of the asynchronous result Annotations @Override

public Future<Void> write(T body)

Implements io.vertx.core.eventbus.MessageProducer.write.

Doc from io.vertx.core.eventbus.MessageProducer.write.

Like write(Object, Handler) but returns a Future of the asynchronous result

Annotations

@Override

write back to summary

write	back to summary
public void write(T body, Handler<AsyncResult<Void>> handler) Implements io.vertx.core.eventbus.MessageProducer.write. Doc from io.vertx.core.eventbus.MessageProducer.write. Write a message to the event-bus, either sending or publishing. The `handler` completion depends on the producer type: send or request: the handler is completed successfully if the message has been written; otherwise, the handler is failed publish: the handler is failed if there is no recipient; otherwise, the handler is completed successfully In any case, a successfully completed `handler` is not a delivery guarantee. Parameters body:T the message body Annotations @Override

public void write(T body, Handler<AsyncResult<Void>> handler)

Implements io.vertx.core.eventbus.MessageProducer.write.

Doc from io.vertx.core.eventbus.MessageProducer.write.

Write a message to the event-bus, either sending or publishing. The handler completion depends on the producer type:

send or request: the handler is completed successfully if the message has been written; otherwise, the handler is failed
publish: the handler is failed if there is no recipient; otherwise, the handler is completed successfully

In any case, a successfully completed handler is not a delivery guarantee.

Parameters

body:T: the message body

Annotations

@Override

write	back to summary
private void write(T data, Promise<Void> handler)

public Class MessageProducerImpl<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail