io.vertx.core.eventbus.impl

pack-priv Class ReplyHandler<T>

Class Inheritance

extends HandlerRegistration<T>
implements Handler<Long>

java.lang.Object
io.vertx.core.eventbus.impl.HandlerRegistration
io.vertx.core.eventbus.impl.ReplyHandler

All Implemented Interfaces

io.vertx.core.Handler

Imports

io.vertx.core.Future, .Handler, .Promise, io.vertx.core.eventbus.Message, .ReplyException, .ReplyFailure, io.vertx.core.impl.ContextInternal, io.vertx.core.spi.tracing.TagExtractor, .VertxTracer

Field Summary

Modifier and Type	Field and Description
private final ContextInternal	context Hides io.vertx.core.eventbus.impl.HandlerRegistration.context.
private final EventBusImpl	eventBus
private final String	repliedAddress
private final Promise<Message<T>>	result
private final boolean	src Hides io.vertx.core.eventbus.impl.HandlerRegistration.src.
private final long	timeout
private final long	timeoutID
pack-priv Object	trace

Inherited from io.vertx.core.eventbus.impl.HandlerRegistration:: address bus

Constructor Summary

Access	Constructor and Description
pack-priv	ReplyHandler(EventBusImpl eventBus, ContextInternal context, String address, String repliedAddress, boolean src, long timeout)

Method Summary

Modifier and Type	Method and Description
protected void	dispatch(Message<T> reply, ContextInternal context, Handler<Message<T>> handler) Implements abstract io.vertx.core.eventbus.impl.HandlerRegistration.dispatch.
private void	doFail(ReplyException failure)
protected boolean	doReceive(Message<T> reply) Implements abstract io.vertx.core.eventbus.impl.HandlerRegistration.doReceive.
pack-priv void	fail(ReplyException failure)
public void	handle(Long the event to handle id) Implements io.vertx.core.Handler.handle. Something has happened, so handle it.
pack-priv void	register()
pack-priv Future<Message<T>>	result()
private void	trace(Object reply, Throwable failure)

Inherited from io.vertx.core.eventbus.impl.HandlerRegistration:: close discard dispatch isRegistered receive register unregister unregister

Field Detail

context	back to summary
private final ContextInternal context Hides io.vertx.core.eventbus.impl.HandlerRegistration.context.

eventBus	back to summary
private final EventBusImpl eventBus

repliedAddress	back to summary
private final String repliedAddress

result	back to summary
private final Promise<Message<T>> result

src	back to summary
private final boolean src Hides io.vertx.core.eventbus.impl.HandlerRegistration.src.

timeout	back to summary
private final long timeout

timeoutID	back to summary
private final long timeoutID

trace	back to summary
pack-priv Object trace

Constructor Detail

ReplyHandler	back to summary
pack-priv ReplyHandler(EventBusImpl eventBus, ContextInternal context, String address, String repliedAddress, boolean src, long timeout)

Method Detail

dispatch	back to summary
protected void dispatch(Message<T> reply, ContextInternal context, Handler<Message<T>> handler) Implements abstract io.vertx.core.eventbus.impl.HandlerRegistration.dispatch. Annotations @Override

dispatch

back to summary

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

Implements abstract io.vertx.core.eventbus.impl.HandlerRegistration.dispatch.

Annotations

@Override

doFail	back to summary
private void doFail(ReplyException failure)

doReceive	back to summary
protected boolean doReceive(Message<T> reply) Implements abstract io.vertx.core.eventbus.impl.HandlerRegistration.doReceive. Annotations @Override

doReceive

back to summary

protected boolean doReceive(Message<T> reply)

Implements abstract io.vertx.core.eventbus.impl.HandlerRegistration.doReceive.

Annotations

@Override

fail	back to summary
pack-priv void fail(ReplyException failure)

handle	back to summary
public void handle(Long id) Implements io.vertx.core.Handler.handle. Doc from io.vertx.core.Handler.handle. Something has happened, so handle it. Parameters id:Long the event to handle Annotations @Override

handle

back to summary

public void handle(Long id)

Implements io.vertx.core.Handler.handle.

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

Something has happened, so handle it.

Parameters

id:Long: the event to handle

Annotations

@Override

register	back to summary
pack-priv void register()

result	back to summary
pack-priv Future<Message<T>> result()

trace	back to summary
private void trace(Object reply, Throwable failure)