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

public Class OutboundDeliveryContext<T>

extends DeliveryContextBase<T>
implements Handler<AsyncResult<Void>>
Class Inheritance
All Implemented Interfaces
io.vertx.core.Handler
Imports
io.vertx.core.AsyncResult, .Handler, .Promise, io.vertx.core.eventbus.DeliveryOptions, .ReplyException, io.vertx.core.eventbus.impl.clustered.ClusteredMessage, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.metrics.EventBusMetrics, io.vertx.core.spi.tracing.SpanKind, .TagExtractor, .VertxTracer, io.vertx.core.tracing.TracingPolicy, java.util.function.BiConsumer

Field Summary

Modifier and TypeField and Description
pack-priv EventBusImpl
bus

public final ContextInternal
ctx

pack-priv EventBusMetrics<H>
metrics

public final DeliveryOptions
options

public final ReplyHandler<T>
replyHandler

private boolean
src

private final Promise<Void>
writePromise

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

Constructor Summary

AccessConstructor and Description
pack-priv
OutboundDeliveryContext(ContextInternal ctx, MessageImpl<U, V> message, DeliveryOptions options, ReplyHandler<T> replyHandler, Promise<Void> writePromise)

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 void
handle(AsyncResult<Void>
the event to handle
event)

Implements io.vertx.core.Handler.handle.

Something has happened, so handle it.

public boolean
send()

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

public void
written(Throwable failure)

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

Field Detail

busback to summary
pack-priv EventBusImpl bus
ctxback to summary
public final ContextInternal ctx
metricsback to summary
pack-priv EventBusMetrics<H> metrics
optionsback to summary
public final DeliveryOptions options
replyHandlerback to summary
public final ReplyHandler<T> replyHandler
srcback to summary
private boolean src
writePromiseback to summary
private final Promise<Void> writePromise

Constructor Detail

OutboundDeliveryContextback to summary
pack-priv OutboundDeliveryContext(ContextInternal ctx, MessageImpl<U, V> message, DeliveryOptions options, ReplyHandler<T> replyHandler, Promise<Void> writePromise)

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.

Annotations
@Override
handleback to summary
public void handle(AsyncResult<Void> event)

Implements io.vertx.core.Handler.handle.

Doc from io.vertx.core.Handler.handle.

Something has happened, so handle it.

Parameters
event:AsyncResult<Void>

the event to handle

Annotations
@Override
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
writtenback to summary
public void written(Throwable failure)