Provides feature that can be implemented using a customize Clustered-EventBus

[leotu]

The "VertxImpl.java" constructor method force to create default ClusteredEventBus implementation, there is no way to create my specific implementation.

public class VertxImpl implements VertxInternal, MetricsProvider {
...
 private final EventBusInternal eventBus;
...
 VertxImpl(VertxOptions options, ClusterManager clusterManager, NodeSelector nodeSelector, VertxMetrics metrics, VertxTracer<?, ?> tracer, Transport transport, FileResolver fileResolver) {
 ...
 ...
 this.eventBus = clusterManager != null ? new ClusteredEventBus(this, options, clusterManager, nodeSelector) : new EventBusImpl(this);
 ...
 ...
}

[vietj]

what is your actual use of having a different event bus implementation ?

[leotu]

I want to my ClusteredEventBus to use WebSocket instead of NetClient, and it may support retry strategy when the message pending to pickup another server ASAP.

The possible solution is to extend ClusteredEventBus & ClusteredHandlerHolder override some methods (i,e. sendRemote , writeMessage, ...)

Or even rewrite most the package "io.vertx.core.eventbus.impl.clustered" files.

[vietj]

we will brainstorm with @tsegismont about what we could do for this

On 26 May 2020, at 17:08, leotu [email protected] wrote:

I want to my ClusteredEventBus to use WebSocket instead of NetClient, and it may support retry strategy when the message pending to pickup another server ASAP.

The possible solution is to extend ClusteredEventBus & ClusteredHandlerHolder override some methods (i,e. sendRemote , writeMessage, ...)

Or event rewrite most the package "io.vertx.core.eventbus.impl.clustered" files.

— You are receiving this because you commented. Reply to this email directly, view it on GitHub https://github.com/eclipse-vertx/vert.x/issues/3426#issuecomment-634085103, or unsubscribe https://github.com/notifications/unsubscribe-auth/AABXDCXXHD4PHIERFVVLVHDRTPLN7ANCNFSM4NJ7ZSEA.

[rpax]

How about using the same factory approach that is used for creating the Vertx object?

[vietj]

@rpax what do you mean ?

[rpax]

@rpax what do you mean ?

Sorry for the late response. I meant the old VertxFactory SPI. Seems that is not there anymore :D . But yes, allowing the use of SPI can do the trick