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

Modifier and Type	Field and Description
protected final CodecManager	codecManager
protected final ConcurrentMap<String, ConcurrentCyclicSequence<HandlerHolder<T>>>	handlerMap
private static final AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]>	INBOUND_INTERCEPTORS_UPDATER
private volatile Handler<DeliveryContext<T>>[]	inboundInterceptors
protected final EventBusMetrics<H>	metrics
private static final AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]>	OUTBOUND_INTERCEPTORS_UPDATER
private volatile Handler<DeliveryContext<T>>[]	outboundInterceptors
private final AtomicLong	replySequence
protected volatile boolean	started
protected final VertxInternal	vertx

Access	Constructor and Description
public	EventBusImpl(VertxInternal vertx)

Method Summary

Modifier and Type	Method and Description
public <T> EventBus	addInboundInterceptor(Handler<DeliveryContext<T>> the interceptor interceptor) Implements io.vertx.core.eventbus.EventBus.addInboundInterceptor. Add an interceptor that will be called whenever a message is received by Vert.x
private void	addInterceptor(AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]> updater, Handler<E> interceptor)
private <T> HandlerHolder<T>	addLocalRegistration(String address, HandlerRegistration<T> registration, boolean replyHandler, boolean localOnly)
public <T> EventBus	addOutboundInterceptor(Handler<DeliveryContext<T>> the interceptor interceptor) Implements io.vertx.core.eventbus.EventBus.addOutboundInterceptor. Add an interceptor that will be called whenever a message is sent from Vert.x
protected <T> HandlerHolder<T>	addRegistration(String address, HandlerRegistration<T> registration, boolean replyHandler, boolean localOnly, Promise<Void> promise)
protected void	callCompletionHandlerAsync(Handler<AsyncResult<Void>> completionHandler)
protected void	checkStarted()
public void	close(Promise<Void> promise) Implements io.vertx.core.eventbus.impl.EventBusInternal.close. Close the event bus and release any resources held.
public EventBus	clusterSerializableChecker(Function<String, Boolean> the predicate classNamePredicate) Implements io.vertx.core.eventbus.EventBus.clusterSerializableChecker. Register a predicate to invoke when verifying if an object is forbidden to be encoded/decoded as `io.vertx.core.shareddata.ClusterSerializable`.
public EventBus	codecSelector(Function<Object, String> the codec selector selector) Implements io.vertx.core.eventbus.EventBus.codecSelector. Set selector to be invoked when the bus has not found any codec for a `Message` body.
public <T> MessageConsumer<T>	consumer(MessageConsumerOptions the consumer options options) Implements io.vertx.core.eventbus.EventBus.consumer. Create a message consumer against the specified options address.
public <T> MessageConsumer<T>	consumer(MessageConsumerOptions the consumer options options, Handler<Message<T>> the handler that will process the received messages handler) Implements io.vertx.core.eventbus.EventBus.consumer. Create a consumer and register it against the specified options address.
public <T> MessageConsumer<T>	consumer(String the address that it will register it at address) Implements io.vertx.core.eventbus.EventBus.consumer. Create a message consumer against the specified address.
public <T> MessageConsumer<T>	consumer(String the address that will register it at address, Handler<Message<T>> the handler that will process the received messages handler) Implements io.vertx.core.eventbus.EventBus.consumer. Create a consumer and register it against the specified address.
protected <T> HandlerHolder<T>	createHandlerHolder(HandlerRegistration<T> registration, boolean replyHandler, boolean localOnly, ContextInternal context)
public MessageImpl<U, V>	createMessage(boolean send, boolean localOnly, String address, MultiMap headers, Object body, String codecName)
pack-priv <T> ReplyHandler<T>	createReplyHandler(MessageImpl<U, V> message, boolean src, DeliveryOptions options)
protected ReplyException	deliverMessageLocally(MessageImpl<U, V> msg)
protected String	generateReplyAddress()
public EventBusMetrics<?>	getMetrics() Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Returns the metrics implementation.
pack-priv Handler<DeliveryContext<T>>[]	inboundInterceptors()
private boolean	isLocalOnly(DeliveryOptions options)
protected boolean	isMessageLocal(MessageImpl<U, V> msg)
public boolean	isMetricsEnabled() Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled. Whether the metrics are enabled for this measured object
public <T> MessageConsumer<T>	localConsumer(String the address to register it at address) Implements io.vertx.core.eventbus.EventBus.localConsumer. Like `consumer(String)` but the address won't be propagated across the cluster.
public <T> MessageConsumer<T>	localConsumer(String the address that will register it at address, Handler<Message<T>> the handler that will process the received messages handler) Implements io.vertx.core.eventbus.EventBus.localConsumer. Like `consumer(String, Handler)` but the address won't be propagated across the cluster.
public <T> OutboundDeliveryContext<T>	newSendContext(MessageImpl<U, V> message, DeliveryOptions options, ReplyHandler<T> handler, Promise<Void> writePromise)
protected HandlerHolder<T>	nextHandler(ConcurrentCyclicSequence<HandlerHolder<T>> handlers, boolean messageLocal)
protected <T> void	onLocalRegistration(HandlerHolder<T> handlerHolder, Promise<Void> promise)
protected <T> void	onLocalUnregistration(HandlerHolder<T> handlerHolder, Promise<Void> promise)
pack-priv Handler<DeliveryContext<T>>[]	outboundInterceptors()
public EventBus	publish(String address, Object message)
public EventBus	publish(String address, Object message, DeliveryOptions options)
public <T> MessageProducer<T>	publisher(String The address to publish it to address) Implements io.vertx.core.eventbus.EventBus.publisher. Create a message publisher against the specified address.
public <T> MessageProducer<T>	publisher(String the address to publish it to address, DeliveryOptions the delivery options options) Implements io.vertx.core.eventbus.EventBus.publisher. Like `publisher(String)` but specifying delivery options that will be used for configuring the delivery of the message.
public EventBus	registerCodec(MessageCodec<S, R> the message codec to register codec) Implements io.vertx.core.eventbus.EventBus.registerCodec. Register a message codec.
public <T> EventBus	registerDefaultCodec(Class<T> the class for which to use this codec clazz, MessageCodec<T, ?> the message codec to register codec) Implements io.vertx.core.eventbus.EventBus.registerDefaultCodec. Register a default message codec.
public <T> EventBus	removeInboundInterceptor(Handler<DeliveryContext<T>> the interceptor interceptor) Implements io.vertx.core.eventbus.EventBus.removeInboundInterceptor. Remove an interceptor that was added by `addInboundInterceptor(Handler)`
private void	removeInterceptor(AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]> updater, Handler<E> interceptor)
private <T> void	removeLocalRegistration(HandlerHolder<T> holder)
public <T> EventBus	removeOutboundInterceptor(Handler<DeliveryContext<T>> the interceptor interceptor) Implements io.vertx.core.eventbus.EventBus.removeOutboundInterceptor. Remove an interceptor that was added by `addOutboundInterceptor(Handler)`
protected <T> void	removeRegistration(HandlerHolder<T> handlerHolder, Promise<Void> promise)
public <T> Future<Message<T>>	request(String address, Object message, DeliveryOptions options)
public EventBus	send(String address, Object message)
public EventBus	send(String address, Object message, DeliveryOptions options)
public <T> MessageProducer<T>	sender(String the address to send it to address) Implements io.vertx.core.eventbus.EventBus.sender. Create a message sender against the specified address.
public <T> MessageProducer<T>	sender(String the address to send it to address, DeliveryOptions the delivery options options) Implements io.vertx.core.eventbus.EventBus.sender. Like `sender(String)` but specifying delivery options that will be used for configuring the delivery of the message.
private <T> void	sendLocally(OutboundDeliveryContext<T> sendContext)
protected <T> void	sendOrPub(OutboundDeliveryContext<T> sendContext)
public <T> void	sendOrPubInternal(OutboundDeliveryContext<T> senderCtx)
public <T> void	sendOrPubInternal(MessageImpl<U, V> message, DeliveryOptions options, ReplyHandler<T> handler, Promise<Void> writePromise)
protected <T> void	sendReply(MessageImpl<U, V> replyMessage, DeliveryOptions options, ReplyHandler<T> replyHandler)
public EventBus	serializableChecker(Function<String, Boolean> the predicate classNamePredicate) Implements io.vertx.core.eventbus.EventBus.serializableChecker. Register a predicate to invoke when verifying if an object is allowed to be encoded/decoded as `java.io.Serializable`.
public synchronized void	start(Promise<Void> promise) Implements io.vertx.core.eventbus.impl.EventBusInternal.start. Start the event bus.
private Future<Void>	unregisterAll()
public EventBus	unregisterCodec(String the name of the codec name) Implements io.vertx.core.eventbus.EventBus.unregisterCodec. Unregister a message codec.
public EventBus	unregisterDefaultCodec(Class<T> the class for which the codec was registered clazz) Implements io.vertx.core.eventbus.EventBus.unregisterDefaultCodec. Unregister a default message codec.

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

codecManager	back to summary
protected final CodecManager codecManager

handlerMap	back to summary
protected final ConcurrentMap<String, ConcurrentCyclicSequence<HandlerHolder<T>>> handlerMap

INBOUND_INTERCEPTORS_UPDATER	back to summary
private static final AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]> INBOUND_INTERCEPTORS_UPDATER

inboundInterceptors	back to summary
private volatile Handler<DeliveryContext<T>>[] inboundInterceptors

metrics	back to summary
protected final EventBusMetrics<H> metrics

OUTBOUND_INTERCEPTORS_UPDATER	back to summary
private static final AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]> OUTBOUND_INTERCEPTORS_UPDATER

outboundInterceptors	back to summary
private volatile Handler<DeliveryContext<T>>[] outboundInterceptors

replySequence	back to summary
private final AtomicLong replySequence

started	back to summary
protected volatile boolean started

vertx	back to summary
protected final VertxInternal vertx

EventBusImpl	back to summary
public EventBusImpl(VertxInternal vertx)

Method Detail

addInboundInterceptor	back to summary
public <T> EventBus addInboundInterceptor(Handler<DeliveryContext<T>> interceptor) Implements io.vertx.core.eventbus.EventBus.addInboundInterceptor. Doc from io.vertx.core.eventbus.EventBus.addInboundInterceptor. Add an interceptor that will be called whenever a message is received by Vert.x Parameters interceptor:Handler<DeliveryContext<T>> the interceptor Returns:EventBus a reference to this, so the API can be used fluently Annotations @Override

addInboundInterceptor

back to summary

public <T> EventBus addInboundInterceptor(Handler<DeliveryContext<T>> interceptor)

Implements io.vertx.core.eventbus.EventBus.addInboundInterceptor.

Doc from io.vertx.core.eventbus.EventBus.addInboundInterceptor.

Add an interceptor that will be called whenever a message is received by Vert.x

Parameters

interceptor:Handler<DeliveryContext<T>>: the interceptor

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

addInterceptor	back to summary
private void addInterceptor(AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]> updater, Handler<E> interceptor)

addLocalRegistration	back to summary
private <T> HandlerHolder<T> addLocalRegistration(String address, HandlerRegistration<T> registration, boolean replyHandler, boolean localOnly)

addOutboundInterceptor	back to summary
public <T> EventBus addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor) Implements io.vertx.core.eventbus.EventBus.addOutboundInterceptor. Doc from io.vertx.core.eventbus.EventBus.addOutboundInterceptor. Add an interceptor that will be called whenever a message is sent from Vert.x Parameters interceptor:Handler<DeliveryContext<T>> the interceptor Returns:EventBus a reference to this, so the API can be used fluently Annotations @Override

addOutboundInterceptor

back to summary

public <T> EventBus addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)

Implements io.vertx.core.eventbus.EventBus.addOutboundInterceptor.

Doc from io.vertx.core.eventbus.EventBus.addOutboundInterceptor.

Add an interceptor that will be called whenever a message is sent from Vert.x

Parameters

interceptor:Handler<DeliveryContext<T>>: the interceptor

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

addRegistration	back to summary
protected <T> HandlerHolder<T> addRegistration(String address, HandlerRegistration<T> registration, boolean replyHandler, boolean localOnly, Promise<Void> promise)

callCompletionHandlerAsync	back to summary
protected void callCompletionHandlerAsync(Handler<AsyncResult<Void>> completionHandler)

checkStarted	back to summary
protected void checkStarted()

close	back to summary
public void close(Promise<Void> promise) Implements io.vertx.core.eventbus.impl.EventBusInternal.close. Doc from io.vertx.core.eventbus.impl.EventBusInternal.close. Close the event bus and release any resources held. Annotations @Override

back to summary

public void close(Promise<Void> promise)

Implements io.vertx.core.eventbus.impl.EventBusInternal.close.

Doc from io.vertx.core.eventbus.impl.EventBusInternal.close.

Close the event bus and release any resources held.

Annotations

@Override

clusterSerializableChecker back to summary

clusterSerializableChecker	back to summary
public EventBus clusterSerializableChecker(Function<String, Boolean> classNamePredicate) Implements io.vertx.core.eventbus.EventBus.clusterSerializableChecker. Doc from io.vertx.core.eventbus.EventBus.clusterSerializableChecker. Register a predicate to invoke when verifying if an object is forbidden to be encoded/decoded as `io.vertx.core.shareddata.ClusterSerializable`. This is only used when Vert.x is clustered. Parameters classNamePredicate:Function<String, Boolean> the predicate Returns:EventBus a reference to this, so the API can be used fluently Annotations @Override

public EventBus clusterSerializableChecker(Function<String, Boolean> classNamePredicate)

Implements io.vertx.core.eventbus.EventBus.clusterSerializableChecker.

Doc from io.vertx.core.eventbus.EventBus.clusterSerializableChecker.

Register a predicate to invoke when verifying if an object is forbidden to be encoded/decoded as io.vertx.core.shareddata.ClusterSerializable.

This is only used when Vert.x is clustered.

Parameters

classNamePredicate:Function<String, Boolean>: the predicate

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

codecSelector back to summary

codecSelector	back to summary
public EventBus codecSelector(Function<Object, String> selector) Implements io.vertx.core.eventbus.EventBus.codecSelector. Doc from io.vertx.core.eventbus.EventBus.codecSelector. Set selector to be invoked when the bus has not found any codec for a `Message` body. The selector must return the name of a codec which has been registered with either `registerCodec(MessageCodec)` or `registerDefaultCodec(Class, MessageCodec)`. Parameters selector:Function<Object, String> the codec selector Returns:EventBus a reference to this, so the API can be used fluently Annotations @Override

public EventBus codecSelector(Function<Object, String> selector)

Implements io.vertx.core.eventbus.EventBus.codecSelector.

Doc from io.vertx.core.eventbus.EventBus.codecSelector.

Set selector to be invoked when the bus has not found any codec for a Message body.

The selector must return the name of a codec which has been registered with either registerCodec(MessageCodec) or registerDefaultCodec(Class, MessageCodec).

Parameters

selector:Function<Object, String>: the codec selector

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

consumer back to summary

consumer	back to summary
public <T> MessageConsumer<T> consumer(MessageConsumerOptions options) Implements io.vertx.core.eventbus.EventBus.consumer. Doc from io.vertx.core.eventbus.EventBus.consumer. Create a message consumer against the specified options address. The returned consumer is not yet registered at the address, registration will be effective when `MessageConsumer#handler(io.vertx.core.Handler)` is called. Parameters options:MessageConsumerOptions the consumer options Returns:MessageConsumer<T> the event bus message consumer Annotations @Override

public <T> MessageConsumer<T> consumer(MessageConsumerOptions options)

Implements io.vertx.core.eventbus.EventBus.consumer.

Doc from io.vertx.core.eventbus.EventBus.consumer.

Create a message consumer against the specified options address.

The returned consumer is not yet registered at the address, registration will be effective when MessageConsumer#handler(io.vertx.core.Handler) is called.

Parameters

options:MessageConsumerOptions: the consumer options

Returns:MessageConsumer<T>

the event bus message consumer

Annotations

@Override

consumer	back to summary
public <T> MessageConsumer<T> consumer(MessageConsumerOptions options, Handler<Message<T>> handler) Implements io.vertx.core.eventbus.EventBus.consumer. Doc from io.vertx.core.eventbus.EventBus.consumer. Create a consumer and register it against the specified options address. Parameters options:MessageConsumerOptions the consumer options handler:Handler<Message<T>> the handler that will process the received messages Returns:MessageConsumer<T> the event bus message consumer Annotations @Override

consumer

back to summary

public <T> MessageConsumer<T> consumer(MessageConsumerOptions options, Handler<Message<T>> handler)

Implements io.vertx.core.eventbus.EventBus.consumer.

Doc from io.vertx.core.eventbus.EventBus.consumer.

Create a consumer and register it against the specified options address.

Parameters

options:MessageConsumerOptions: the consumer options
handler:Handler<Message<T>>: the handler that will process the received messages

Returns:MessageConsumer<T>

the event bus message consumer

Annotations

@Override

consumer back to summary

consumer	back to summary
public <T> MessageConsumer<T> consumer(String address) Implements io.vertx.core.eventbus.EventBus.consumer. Doc from io.vertx.core.eventbus.EventBus.consumer. Create a message consumer against the specified address. The returned consumer is not yet registered at the address, registration will be effective when `MessageConsumer#handler(io.vertx.core.Handler)` is called. Parameters address:String the address that it will register it at Returns:MessageConsumer<T> the event bus message consumer Annotations @Override

public <T> MessageConsumer<T> consumer(String address)

Implements io.vertx.core.eventbus.EventBus.consumer.

Doc from io.vertx.core.eventbus.EventBus.consumer.

Create a message consumer against the specified address.

The returned consumer is not yet registered at the address, registration will be effective when MessageConsumer#handler(io.vertx.core.Handler) is called.

Parameters

address:String: the address that it will register it at

Returns:MessageConsumer<T>

the event bus message consumer

Annotations

@Override

consumer	back to summary
public <T> MessageConsumer<T> consumer(String address, Handler<Message<T>> handler) Implements io.vertx.core.eventbus.EventBus.consumer. Doc from io.vertx.core.eventbus.EventBus.consumer. Create a consumer and register it against the specified address. Parameters address:String the address that will register it at handler:Handler<Message<T>> the handler that will process the received messages Returns:MessageConsumer<T> the event bus message consumer Annotations @Override

consumer

back to summary

public <T> MessageConsumer<T> consumer(String address, Handler<Message<T>> handler)

Implements io.vertx.core.eventbus.EventBus.consumer.

Doc from io.vertx.core.eventbus.EventBus.consumer.

Create a consumer and register it against the specified address.

Parameters

address:String: the address that will register it at
handler:Handler<Message<T>>: the handler that will process the received messages

Returns:MessageConsumer<T>

the event bus message consumer

Annotations

@Override

createHandlerHolder	back to summary
protected <T> HandlerHolder<T> createHandlerHolder(HandlerRegistration<T> registration, boolean replyHandler, boolean localOnly, ContextInternal context)

createMessage	back to summary
public MessageImpl<U, V> createMessage(boolean send, boolean localOnly, String address, MultiMap headers, Object body, String codecName)

createReplyHandler	back to summary
pack-priv <T> ReplyHandler<T> createReplyHandler(MessageImpl<U, V> message, boolean src, DeliveryOptions options)

deliverMessageLocally	back to summary
protected ReplyException deliverMessageLocally(MessageImpl<U, V> msg)

generateReplyAddress	back to summary
protected String generateReplyAddress()

getMetrics	back to summary
public EventBusMetrics<?> getMetrics() Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Doc from io.vertx.core.spi.metrics.MetricsProvider.getMetrics. Returns the metrics implementation. Returns:EventBusMetrics<?> the metrics Annotations @Override

getMetrics

back to summary

public EventBusMetrics<?> getMetrics()

Implements io.vertx.core.spi.metrics.MetricsProvider.getMetrics.

Doc from io.vertx.core.spi.metrics.MetricsProvider.getMetrics.

Returns the metrics implementation.

Returns:EventBusMetrics<?>

the metrics

Annotations

@Override

inboundInterceptors	back to summary
pack-priv Handler<DeliveryContext<T>>[] inboundInterceptors()

isLocalOnly	back to summary
private boolean isLocalOnly(DeliveryOptions options)

isMessageLocal	back to summary
protected boolean isMessageLocal(MessageImpl<U, V> msg)

isMetricsEnabled back to summary

isMetricsEnabled	back to summary
public boolean isMetricsEnabled() Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled. Doc from io.vertx.core.metrics.Measured.isMetricsEnabled. Whether the metrics are enabled for this measured object Returns:boolean `true` if metrics are enabled Annotations @Override

public boolean isMetricsEnabled()

Overrides default io.vertx.core.metrics.Measured.isMetricsEnabled.

Doc from io.vertx.core.metrics.Measured.isMetricsEnabled.

Whether the metrics are enabled for this measured object

Returns:boolean

true if metrics are enabled

Annotations

@Override

localConsumer back to summary

localConsumer	back to summary
public <T> MessageConsumer<T> localConsumer(String address) Implements io.vertx.core.eventbus.EventBus.localConsumer. Doc from io.vertx.core.eventbus.EventBus.localConsumer. Like `consumer(String)` but the address won't be propagated across the cluster. Parameters address:String the address to register it at Returns:MessageConsumer<T> the event bus message consumer Annotations @Override

public <T> MessageConsumer<T> localConsumer(String address)

Implements io.vertx.core.eventbus.EventBus.localConsumer.

Doc from io.vertx.core.eventbus.EventBus.localConsumer.

Like consumer(String) but the address won't be propagated across the cluster.

Parameters

address:String: the address to register it at

Returns:MessageConsumer<T>

the event bus message consumer

Annotations

@Override

localConsumer back to summary

localConsumer	back to summary
public <T> MessageConsumer<T> localConsumer(String address, Handler<Message<T>> handler) Implements io.vertx.core.eventbus.EventBus.localConsumer. Doc from io.vertx.core.eventbus.EventBus.localConsumer. Like `consumer(String, Handler)` but the address won't be propagated across the cluster. Parameters address:String the address that will register it at handler:Handler<Message<T>> the handler that will process the received messages Returns:MessageConsumer<T> the event bus message consumer Annotations @Override

public <T> MessageConsumer<T> localConsumer(String address, Handler<Message<T>> handler)

Implements io.vertx.core.eventbus.EventBus.localConsumer.

Doc from io.vertx.core.eventbus.EventBus.localConsumer.

Like consumer(String, Handler) but the address won't be propagated across the cluster.

Parameters

address:String: the address that will register it at
handler:Handler<Message<T>>: the handler that will process the received messages

Returns:MessageConsumer<T>

the event bus message consumer

Annotations

@Override

newSendContext	back to summary
public <T> OutboundDeliveryContext<T> newSendContext(MessageImpl<U, V> message, DeliveryOptions options, ReplyHandler<T> handler, Promise<Void> writePromise)

nextHandler	back to summary
protected HandlerHolder<T> nextHandler(ConcurrentCyclicSequence<HandlerHolder<T>> handlers, boolean messageLocal)

onLocalRegistration	back to summary
protected <T> void onLocalRegistration(HandlerHolder<T> handlerHolder, Promise<Void> promise)

onLocalUnregistration	back to summary
protected <T> void onLocalUnregistration(HandlerHolder<T> handlerHolder, Promise<Void> promise)

outboundInterceptors	back to summary
pack-priv Handler<DeliveryContext<T>>[] outboundInterceptors()

publish	back to summary
public EventBus publish(String address, Object message) Annotations @Override

publish	back to summary
public EventBus publish(String address, Object message, DeliveryOptions options) Annotations @Override

publisher back to summary

publisher	back to summary
public <T> MessageProducer<T> publisher(String address) Implements io.vertx.core.eventbus.EventBus.publisher. Doc from io.vertx.core.eventbus.EventBus.publisher. Create a message publisher against the specified address. The returned publisher will invoke the `publish(String, Object)` method when the stream `io.vertx.core.streams.WriteStream#write(Object)` method is called with the publisher address and the provided data. Parameters address:String The address to publish it to Returns:MessageProducer<T> The publisher Annotations @Override

public <T> MessageProducer<T> publisher(String address)

Implements io.vertx.core.eventbus.EventBus.publisher.

Doc from io.vertx.core.eventbus.EventBus.publisher.

Create a message publisher against the specified address.

The returned publisher will invoke the publish(String, Object) method when the stream io.vertx.core.streams.WriteStream#write(Object) method is called with the publisher address and the provided data.

Parameters

address:String: The address to publish it to

Returns:MessageProducer<T>

The publisher

Annotations

@Override

publisher back to summary

publisher	back to summary
public <T> MessageProducer<T> publisher(String address, DeliveryOptions options) Implements io.vertx.core.eventbus.EventBus.publisher. Doc from io.vertx.core.eventbus.EventBus.publisher. Like `publisher(String)` but specifying delivery options that will be used for configuring the delivery of the message. Parameters address:String the address to publish it to options:DeliveryOptions the delivery options Returns:MessageProducer<T> The publisher Annotations @Override

public <T> MessageProducer<T> publisher(String address, DeliveryOptions options)

Implements io.vertx.core.eventbus.EventBus.publisher.

Doc from io.vertx.core.eventbus.EventBus.publisher.

Like publisher(String) but specifying delivery options that will be used for configuring the delivery of the message.

Parameters

address:String: the address to publish it to
options:DeliveryOptions: the delivery options

Returns:MessageProducer<T>

The publisher

Annotations

@Override

registerCodec	back to summary
public EventBus registerCodec(MessageCodec<S, R> codec) Implements io.vertx.core.eventbus.EventBus.registerCodec. Doc from io.vertx.core.eventbus.EventBus.registerCodec. Register a message codec. You can register a message codec if you want to send any non standard message across the event bus. E.g. you might want to send POJOs directly across the event bus. To use a message codec for a send, you should specify it in the delivery options. Parameters codec:MessageCodec<S, R> the message codec to register Returns:EventBus a reference to this, so the API can be used fluently Annotations @Override

registerCodec

back to summary

public EventBus registerCodec(MessageCodec<S, R> codec)

Implements io.vertx.core.eventbus.EventBus.registerCodec.

Doc from io.vertx.core.eventbus.EventBus.registerCodec.

You can register a message codec if you want to send any non standard message across the event bus. E.g. you might want to send POJOs directly across the event bus.

To use a message codec for a send, you should specify it in the delivery options.

Parameters

codec:MessageCodec<S, R>: the message codec to register

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

registerDefaultCodec

back to summary

public <T> EventBus registerDefaultCodec(Class<T> clazz, MessageCodec<T, ?> codec)

Implements io.vertx.core.eventbus.EventBus.registerDefaultCodec.

Doc from io.vertx.core.eventbus.EventBus.registerDefaultCodec.

You can register a message codec if you want to send any non standard message across the event bus. E.g. you might want to send POJOs directly across the event bus.

Default message codecs will be used to serialise any messages of the specified type on the event bus without the codec having to be specified in the delivery options.

Parameters

clazz:Class<T>: the class for which to use this codec
codec:MessageCodec<T, ?>: the message codec to register

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

removeInboundInterceptor back to summary

public <T> EventBus removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)

Implements io.vertx.core.eventbus.EventBus.removeInboundInterceptor.

Doc from io.vertx.core.eventbus.EventBus.removeInboundInterceptor.

Remove an interceptor that was added by addInboundInterceptor(Handler)

Parameters

interceptor:Handler<DeliveryContext<T>>: the interceptor

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

removeInterceptor	back to summary
private void removeInterceptor(AtomicReferenceFieldUpdater<EventBusImpl, Handler<E>[]> updater, Handler<E> interceptor)

removeLocalRegistration	back to summary
private <T> void removeLocalRegistration(HandlerHolder<T> holder)

removeOutboundInterceptor back to summary

public <T> EventBus removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)

Implements io.vertx.core.eventbus.EventBus.removeOutboundInterceptor.

Doc from io.vertx.core.eventbus.EventBus.removeOutboundInterceptor.

Remove an interceptor that was added by addOutboundInterceptor(Handler)

Parameters

interceptor:Handler<DeliveryContext<T>>: the interceptor

Returns:EventBus

a reference to this, so the API can be used fluently

Annotations

@Override

removeRegistration	back to summary
protected <T> void removeRegistration(HandlerHolder<T> handlerHolder, Promise<Void> promise)

request	back to summary
public <T> Future<Message<T>> request(String address, Object message, DeliveryOptions options) Annotations @Override

send	back to summary
public EventBus send(String address, Object message) Annotations @Override

send	back to summary
public EventBus send(String address, Object message, DeliveryOptions options) Annotations @Override

sender back to summary

public <T> MessageProducer<T> sender(String address)

Implements io.vertx.core.eventbus.EventBus.sender.

Doc from io.vertx.core.eventbus.EventBus.sender.

Create a message sender against the specified address.

The returned sender will invoke the send(String, Object) method when the stream io.vertx.core.streams.WriteStream#write(Object) method is called with the sender address and the provided data.

Parameters