Package com.inductiveautomation.eventstream.gateway.eventbus

Class EventStreamEventBus

java.lang.Object

com.inductiveautomation.eventstream.gateway.eventbus.EventStreamEventBus

Direct Known Subclasses:

GanEventStreamEventBus

public class EventStreamEventBus
extends Object

Local message bus for sending messages to GatewayEventSource

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	EventStreamEventBus.Listener
static final record	EventStreamEventBus.Payload

Constructor Summary

Constructors

Constructor	Description
EventStreamEventBus(ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
final CompletableFuture<EventResult>	execute(Supplier<CompletableFuture<EventResult>> callable)
final void	registerListener(String project, String path, EventStreamEventBus.Listener listener)
CompletableFuture<EventResult>	send(EventStreamEventBus.Payload payload)
protected final CompletableFuture<EventResult>	sendLocal(EventStreamEventBus.Payload payload)
void	shutdown()
void	startup(EventStreamManager manager)
final void	unregisterListener(String project, String path)

Methods inherited from class java.lang.Object

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

Constructor Details

EventStreamEventBus

public EventStreamEventBus(ExecutorService executor)

Method Details

startup

public void startup(EventStreamManager manager)

shutdown

public void shutdown()

registerListener

public final void registerListener(String project,
 String path,
 EventStreamEventBus.Listener listener)

unregisterListener

public final void unregisterListener(String project,
 String path)

send

public CompletableFuture<EventResult> send(EventStreamEventBus.Payload payload)

execute

public final CompletableFuture<EventResult> execute(Supplier<CompletableFuture<EventResult>> callable)

sendLocal

protected final CompletableFuture<EventResult> sendLocal(EventStreamEventBus.Payload payload)