GanEventStreamEventBus

java.lang.Object

com.inductiveautomation.eventstream.gateway.eventbus.EventStreamEventBus

com.inductiveautomation.eventstream.gateway.eventbus.GanEventStreamEventBus

public class GanEventStreamEventBus extends EventStreamEventBus

Adds ability to send messages through GAN.

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static interface

GanEventStreamEventBus.Service

Nested classes/interfaces inherited from class com.inductiveautomation.eventstream.gateway.eventbus.EventStreamEventBus
EventStreamEventBus.Listener, EventStreamEventBus.Payload
Constructor Summary

Constructors

Constructor

Description

GanEventStreamEventBus(ExecutorService executorService, GatewayNetworkManager ganManager)
Method Summary

Modifier and Type

Method

Description

CompletableFuture<EventResult>

send(EventStreamEventBus.Payload payload)

void

shutdown()

void

startup(EventStreamManager manager)

Methods inherited from class com.inductiveautomation.eventstream.gateway.eventbus.EventStreamEventBus
execute, registerListener, sendLocal, unregisterListener

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- GanEventStreamEventBus
  
  public GanEventStreamEventBus(ExecutorService executorService, GatewayNetworkManager ganManager)
Method Details
- startup
  
  public void startup(EventStreamManager manager)
  
  Overrides:
  
  startup in class EventStreamEventBus
- shutdown
  
  public void shutdown()
  
  Overrides:
  
  shutdown in class EventStreamEventBus
- send
  
  public CompletableFuture<EventResult> send(EventStreamEventBus.Payload payload)
  
  Overrides:
  
  send in class EventStreamEventBus