Package com.couchbase.client.core.cnc

Class SimpleEventBus

java.lang.Object

com.couchbase.client.core.cnc.SimpleEventBus

All Implemented Interfaces:

EventBus

@Internal
public class SimpleEventBus
extends Object
implements EventBus

This super simple event bus should be used in testing only to assert certain events got pushed through.

Nested Class Summary

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

EventBus.PublishResult

Constructor Summary

Constructors

Constructor	Description
SimpleEventBus(boolean ignoreSystemEvents)	Creates a new SimpleEventBus.
SimpleEventBus(boolean ignoreSystemEvents, List<Class<? extends Event>> othersToIgnore)	Creates a new SimpleEventBus.

Method Summary

Modifier and Type	Method	Description
void	clear()
EventBus.PublishResult	publish(Event event)	Try to publish an event.
List<Event>	publishedEvents()
reactor.core.publisher.Mono<Void>	start()	Starts the event bus if it hasn't been started yet.
reactor.core.publisher.Mono<Void>	stop(Duration timeout)	Stops the event bus if it hasn't been stopped already.
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

Constructor Details

SimpleEventBus

public SimpleEventBus(boolean ignoreSystemEvents)

Creates a new SimpleEventBus.

Note that in general you want to ignore system events since they add nondeterminism during assertions when things like garbage collections happen. Of course if you need to test/verify system events, set the argument to false.

Parameters:

ignoreSystemEvents - true if they should be ignored (recommended), false otherwise.

SimpleEventBus

public SimpleEventBus(boolean ignoreSystemEvents,
 List<Class<? extends Event>> othersToIgnore)

Creates a new SimpleEventBus.

Note that in general you want to ignore system events since they add nondeterminism during assertions when things like garbage collections happen. Of course if you need to test/verify system events, set the argument to false.

Parameters:

ignoreSystemEvents - true if they should be ignored (recommended), false otherwise.

othersToIgnore - other list of events to ignore.

Method Details

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.

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.

publishedEvents

public List<Event> publishedEvents()

clear

public void clear()

start

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

Description copied from interface: EventBus

Starts the event bus if it hasn't been started yet.

Specified by:

start in interface EventBus

stop

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

Description copied from interface: EventBus

Stops the event bus if it hasn't been stopped already.

Specified by:

stop in interface EventBus