Top Inners Fields Constructors Methods
io.vertx.core.eventbus.impl

public abstract Class HandlerRegistration<T>

extends Object
implements Closeable
Class Inheritance
All Implemented Interfaces
io.vertx.core.Closeable
Known Direct Subclasses
io.vertx.core.eventbus.impl.MessageConsumerImpl, io.vertx.core.eventbus.impl.ReplyHandler
Imports
io.vertx.core.*, io.vertx.core.eventbus.Message, .ReplyException, .ReplyFailure, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.tracing.SpanKind, .TagExtractor, .VertxTracer, io.vertx.core.tracing.TracingPolicy

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
HandlerRegistration.InboundDeliveryContext

Field Summary

Modifier and TypeField and Description
public final String
address

public final EventBusImpl
bus

public final ContextInternal
context

private Object
metric

private HandlerHolder<T>
registered

public final boolean
src

Constructor Summary

AccessConstructor and Description
pack-priv
HandlerRegistration(ContextInternal context, EventBusImpl bus, String address, boolean src)

Method Summary

Modifier and TypeMethod and Description
public void
close(Promise<Void>
the promise to signal when close has completed
completion)

Implements io.vertx.core.Closeable.close.

Close this resource, the completion promise must be notified when the operation has completed.

pack-priv void
discard(Message<T> msg)

protected abstract void
dispatch(Message<T> msg, ContextInternal context, Handler<Message<T>> handler)

pack-priv void
dispatch(Handler<Message<T>> theHandler, Message<T> message, ContextInternal context)

protected abstract boolean
doReceive(Message<T> msg)

public synchronized boolean
isRegistered()

pack-priv void
receive(MessageImpl<U, V> msg)

pack-priv synchronized void
register(String repliedAddress, boolean localOnly, Promise<Void> promise)

public Future<Void>
unregister()

public void
unregister(Handler<AsyncResult<Void>> completionHandler)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

addressback to summary
public final String address
busback to summary
public final EventBusImpl bus
contextback to summary
public final ContextInternal context
metricback to summary
private Object metric
registeredback to summary
private HandlerHolder<T> registered
srcback to summary
public final boolean src

Constructor Detail

HandlerRegistrationback to summary
pack-priv HandlerRegistration(ContextInternal context, EventBusImpl bus, String address, boolean src)

Method Detail

closeback to summary
public void close(Promise<Void> completion)

Implements io.vertx.core.Closeable.close.

Doc from io.vertx.core.Closeable.close.

Close this resource, the completion promise must be notified when the operation has completed.

Parameters
completion:Promise<Void>

the promise to signal when close has completed

Annotations
@Override
discardback to summary
pack-priv void discard(Message<T> msg)
dispatchback to summary
protected abstract void dispatch(Message<T> msg, ContextInternal context, Handler<Message<T>> handler)
dispatchback to summary
pack-priv void dispatch(Handler<Message<T>> theHandler, Message<T> message, ContextInternal context)
doReceiveback to summary
protected abstract boolean doReceive(Message<T> msg)
isRegisteredback to summary
public synchronized boolean isRegistered()
receiveback to summary
pack-priv void receive(MessageImpl<U, V> msg)
registerback to summary
pack-priv synchronized void register(String repliedAddress, boolean localOnly, Promise<Void> promise)
unregisterback to summary
public Future<Void> unregister()
unregisterback to summary
public void unregister(Handler<AsyncResult<Void>> completionHandler)
io.vertx.core.eventbus.impl back to summary

private Class HandlerRegistration.InboundDeliveryContext

extends DeliveryContextBase<T>
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final Handler<Message<T>>
handler

Inherited from io.vertx.core.eventbus.impl.DeliveryContextBase:
contextmessage

Constructor Summary

AccessConstructor and Description
private
InboundDeliveryContext(MessageImpl<?, T> message, Handler<Message<T>> handler, ContextInternal context)

Method Summary

Modifier and TypeMethod and Description
public Object
body()

Implements io.vertx.core.eventbus.DeliveryContext.body.

protected void
execute()

Implements abstract io.vertx.core.eventbus.impl.DeliveryContextBase.execute.

public boolean
send()

Implements io.vertx.core.eventbus.DeliveryContext.send.

Inherited from io.vertx.core.eventbus.impl.DeliveryContextBase:
dispatchmessagenext

Field Detail

handlerback to summary
private final Handler<Message<T>> handler

Constructor Detail

InboundDeliveryContextback to summary
private InboundDeliveryContext(MessageImpl<?, T> message, Handler<Message<T>> handler, ContextInternal context)

Method Detail

bodyback to summary
public Object body()

Implements io.vertx.core.eventbus.DeliveryContext.body.

Returns:Object

Doc from io.vertx.core.eventbus.DeliveryContext.body.

the value delivered by the message (before or after being processed by the codec)

Annotations
@Override
executeback to summary
protected void execute()

Implements abstract io.vertx.core.eventbus.impl.DeliveryContextBase.execute.

sendback to summary
public boolean send()

Implements io.vertx.core.eventbus.DeliveryContext.send.

Returns:boolean

Doc from io.vertx.core.eventbus.DeliveryContext.send.

true if the message is being sent (point to point) or False if the message is being published

Annotations
@Override