org.trellisldp.reactive

Class ReactiveEventService

java.lang.Object

org.trellisldp.reactive.ReactiveEventService

All Implemented Interfaces:

EventService

@ApplicationScoped
public class ReactiveEventService
extends Object
implements EventService

A microprofile-based event service.

Field Summary

Fields

Modifier and Type	Field and Description
static String	REACTIVE_DESTINATION

Constructor Summary

Constructors

Constructor and Description
ReactiveEventService() Create a new Reactive Stream Event Service with a no-op serializer.
ReactiveEventService(EventSerializationService serializer) Create a new Reactive Stream Event Service.

Method Summary

Modifier and Type	Method and Description
void	emit(Event event) Emit an event to the event service.
io.reactivex.Flowable<org.eclipse.microprofile.reactive.messaging.Message<String>>	publish() Send the event to the reactive stream destination.

Methods inherited from class java.lang.Object

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

Field Detail

REACTIVE_DESTINATION

public static final String REACTIVE_DESTINATION

See Also:

Constant Field Values

Constructor Detail

ReactiveEventService

public ReactiveEventService()

Create a new Reactive Stream Event Service with a no-op serializer.

API Note:

This construtor is used by CDI runtimes that require a public, no-argument constructor. It should not be invoked directly in user code.

ReactiveEventService

@Inject
public ReactiveEventService(EventSerializationService serializer)

Create a new Reactive Stream Event Service.

Parameters:

serializer - the event serializer

Method Detail

emit

public void emit(Event event)

Description copied from interface: EventService

Emit an event to the event service.

Specified by:

emit in interface EventService

Parameters:

event - the event

publish

public io.reactivex.Flowable<org.eclipse.microprofile.reactive.messaging.Message<String>> publish()

Send the event to the reactive stream destination.

Returns:

the flowable stream of messages