public class ClusteredEventBus extends EventBusImpl
EventBusImpl.HandlerEntry<T>, EventBusImpl.InboundDeliveryContext<T>, EventBusImpl.OutboundDeliveryContext<T>| Modifier and Type | Field and Description |
|---|---|
static String |
CLUSTER_PUBLIC_HOST_PROP_NAME |
static String |
CLUSTER_PUBLIC_PORT_PROP_NAME |
codecManager, handlerMap, metrics, started, vertx| Constructor and Description |
|---|
ClusteredEventBus(VertxInternal vertx,
VertxOptions options,
ClusterManager clusterManager) |
| Modifier and Type | Method and Description |
|---|---|
protected <T> void |
addRegistration(boolean newAddress,
String address,
boolean replyHandler,
boolean localOnly,
Handler<AsyncResult<Void>> completionHandler) |
void |
close(Handler<AsyncResult<Void>> completionHandler)
Close the event bus and release any resources held.
|
MessageImpl |
createMessage(boolean send,
String address,
MultiMap headers,
Object body,
String codecName,
Handler<AsyncResult<Void>> writeHandler) |
protected String |
generateReplyAddress() |
protected boolean |
isMessageLocal(MessageImpl msg) |
protected <T> void |
removeRegistration(HandlerHolder<T> lastHolder,
String address,
Handler<AsyncResult<Void>> completionHandler) |
protected <T> void |
sendOrPub(EventBusImpl.OutboundDeliveryContext<T> sendContext) |
protected <T> void |
sendReply(EventBusImpl.OutboundDeliveryContext<T> sendContext,
MessageImpl replierMessage) |
void |
start(Handler<AsyncResult<Void>> resultHandler)
Start the event bus.
|
addInboundInterceptor, addOutboundInterceptor, addRegistration, callCompletionHandlerAsync, checkStarted, consumer, consumer, convertHandler, deliverMessageLocally, deliverMessageLocally, finalize, getMetrics, isMetricsEnabled, localConsumer, localConsumer, publish, publish, publisher, publisher, registerCodec, registerDefaultCodec, removeInboundInterceptor, removeOutboundInterceptor, removeRegistration, send, send, send, send, sender, sender, sendOrPubInternal, sendReply, unregisterCodec, unregisterDefaultCodecpublic static final String CLUSTER_PUBLIC_HOST_PROP_NAME
public static final String CLUSTER_PUBLIC_PORT_PROP_NAME
public ClusteredEventBus(VertxInternal vertx, VertxOptions options, ClusterManager clusterManager)
public void start(Handler<AsyncResult<Void>> resultHandler)
EventBusstart in interface EventBusstart in class EventBusImplresultHandler - handler will be called when event bus is startedpublic void close(Handler<AsyncResult<Void>> completionHandler)
EventBusclose in interface EventBusclose in class EventBusImplcompletionHandler - may be nullpublic MessageImpl createMessage(boolean send, String address, MultiMap headers, Object body, String codecName, Handler<AsyncResult<Void>> writeHandler)
createMessage in class EventBusImplprotected <T> void addRegistration(boolean newAddress,
String address,
boolean replyHandler,
boolean localOnly,
Handler<AsyncResult<Void>> completionHandler)
addRegistration in class EventBusImplprotected <T> void removeRegistration(HandlerHolder<T> lastHolder, String address, Handler<AsyncResult<Void>> completionHandler)
removeRegistration in class EventBusImplprotected <T> void sendReply(EventBusImpl.OutboundDeliveryContext<T> sendContext, MessageImpl replierMessage)
sendReply in class EventBusImplprotected <T> void sendOrPub(EventBusImpl.OutboundDeliveryContext<T> sendContext)
sendOrPub in class EventBusImplprotected String generateReplyAddress()
generateReplyAddress in class EventBusImplprotected boolean isMessageLocal(MessageImpl msg)
isMessageLocal in class EventBusImplCopyright © 2020. All rights reserved.