Package com.couchbase.client.core.cnc

Class DefaultEventBus

java.lang.Object

com.couchbase.client.core.cnc.DefaultEventBus

All Implemented Interfaces:

EventBus

public class DefaultEventBus
extends Object
implements EventBus

The DefaultEventBus provides the default and very efficient implementation of the EventBus.

It is built on top of a very fast, bounded MPSC (multi-producer single-consumer) queue which allows to quickly send events into the bus without blocking the sender.

Subscribers of this API are considered to be non-blocking and if they have to blocking tasks need to fan them out into their own thread pool.

Keep in mind to properly start() and stop(Duration) since it runs in its own thread!

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultEventBus.Builder	Allows to modify the default configuration of the DefaultEventBus.

Nested classes/interfaces inherited from interface com.couchbase.client.core.cnc.EventBus

EventBus.PublishResult

Method Summary

Modifier and Type	Method	Description
static DefaultEventBus.Builder	builder(reactor.core.scheduler.Scheduler scheduler)
static DefaultEventBus	create(reactor.core.scheduler.Scheduler scheduler)
EventBus.PublishResult	publish(Event event)	Try to publish an event.
reactor.core.publisher.Mono<Void>	start()	Starts the DefaultEventBus.
reactor.core.publisher.Mono<Void>	stop(Duration timeout)	Stops the DefaultEventBus from running.
EventSubscription	subscribe(Consumer<Event> consumer)	Subscribes a Consumer to receive Events.
void	unsubscribe(EventSubscription subscription)	Unsubscribes the Consumer from this EventBus.

Methods inherited from class java.lang.Object

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

Method Details

builder

public static DefaultEventBus.Builder builder(reactor.core.scheduler.Scheduler scheduler)

create

public static DefaultEventBus create(reactor.core.scheduler.Scheduler scheduler)

subscribe

public EventSubscription subscribe(Consumer<Event> consumer)

Description copied from interface: EventBus

Subscribes a Consumer to receive Events.

Specified by:

subscribe in interface EventBus

Parameters:

consumer - the consumer which will receive events.

Returns:

a EventSubscription that can be used to unsubscribe.

unsubscribe

public void unsubscribe(EventSubscription subscription)

Description copied from interface: EventBus

Unsubscribes the Consumer from this EventBus.

Specified by:

unsubscribe in interface EventBus

Parameters:

subscription - the subscription used.

publish

public EventBus.PublishResult publish(Event event)

Description copied from interface: EventBus

Try to publish an event.

Specified by:

publish in interface EventBus

Parameters:

event - the event to publish.

Returns:

the EventBus.PublishResult of th event.

start

public reactor.core.publisher.Mono<Void> start()

Starts the DefaultEventBus.

Specified by:

start in interface EventBus

stop

public reactor.core.publisher.Mono<Void> stop(Duration timeout)

Stops the DefaultEventBus from running.

Specified by:

stop in interface EventBus