io.vertx.core.eventbus.impl

Class HandlerRegistration<T>

java.lang.Object

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

All Implemented Interfaces:

Closeable

Direct Known Subclasses:

MessageConsumerImpl

public abstract class HandlerRegistration<T>
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
String	address
EventBusImpl	bus
ContextInternal	context
boolean	src

Method Summary

Modifier and Type	Method and Description
void	close(Promise<Void> completion) Close this resource, the completion promise must be notified when the operation has completed.
protected abstract void	dispatch(Message<T> msg, ContextInternal context, Handler<Message<T>> handler)
protected abstract boolean	doReceive(Message<T> msg)
boolean	isRegistered()
Future<Void>	unregister()
void	unregister(Handler<AsyncResult<Void>> completionHandler)

Methods inherited from class java.lang.Object

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

Field Detail

context

public final ContextInternal context

bus

public final EventBusImpl bus

address

public final String address

src

public final boolean src

Method Detail

doReceive

protected abstract boolean doReceive(Message<T> msg)

dispatch

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

isRegistered

public boolean isRegistered()

unregister

public Future<Void> unregister()

unregister

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

close

public void close(Promise<Void> completion)

Description copied from interface: Closeable

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

Specified by:

close in interface Closeable

Parameters:

completion - the promise to signal when close has completed