io.vertx.core.eventbus.impl

Class OutboundDeliveryContext<T>

java.lang.Object

io.vertx.core.eventbus.impl.OutboundDeliveryContext<T>

All Implemented Interfaces:

DeliveryContext<T>, Handler<AsyncResult<Void>>

public class OutboundDeliveryContext<T>
extends Object
implements DeliveryContext<T>, Handler<AsyncResult<Void>>

Field Summary

Fields

Modifier and Type	Field and Description
ContextInternal	ctx
MessageImpl	message
DeliveryOptions	options
io.vertx.core.eventbus.impl.ReplyHandler<T>	replyHandler

Method Summary

Modifier and Type	Method and Description
Object	body()
void	handle(AsyncResult<Void> event) Something has happened, so handle it.
Message<T>	message()
void	next() Call the next interceptor
boolean	send()
void	written(Throwable failure)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ctx

public final ContextInternal ctx

message

public final MessageImpl message

options

public final DeliveryOptions options

replyHandler

public final io.vertx.core.eventbus.impl.ReplyHandler<T> replyHandler

Method Detail

handle

public void handle(AsyncResult<Void> event)

Description copied from interface: Handler

Something has happened, so handle it.

Specified by:

handle in interface Handler<AsyncResult<Void>>

Parameters:

event - the event to handle

written

public void written(Throwable failure)

message

public Message<T> message()

Specified by:

message in interface DeliveryContext<T>

Returns:

The message being delivered

next

public void next()

Description copied from interface: DeliveryContext

Call the next interceptor

Specified by:

next in interface DeliveryContext<T>

send

public boolean send()

Specified by:

send in interface DeliveryContext<T>

Returns:

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

body

public Object body()

Specified by:

body in interface DeliveryContext<T>

Returns:

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