Package com.northconcepts.datapipeline.eventbus
package com.northconcepts.datapipeline.eventbus
In-memory, publish-subscribe hub using simple Java interfaces or loosely-coupled readers and writers.
-
ClassDescriptionEvent<T>A method call made on an
EventBuspublisher, captured with its arguments for delivery to the bus's listeners.An asynchronous, in-memory, event delivery service.The lifecycle states of a bus; listeners, publishers and events are only accepted whileALIVE.Notified when anyEventBusis created or begins shutting down; register withEventBus.addEventBusLifecycleListener(EventBusLifecycleListener).Reads the records published to anEventBuson the given topics (all topics if none are given), for example by anEventBusWriter.Writes records to an event bus under a specific topic.Decides which events a listener receives; supplied when the listener is added to anEventBus.Backs the publisher proxies returned byEventBus.getPublisher(Object, Class, Object), publishing each method call to the bus as anEvent.Notified when a listener on anEventBusthrows an exception while receiving an event; register withEventBus.addExceptionListener(ExceptionListener).Listener interface for publishing and receiving records on anEventBus, asEventBusWriterandEventBusReaderdo.Notified when anEventBusbegins shutting down; register withEventBus.addShutdownListener(EventFilter, ShutdownListener).Holds the listeners subscribed to anEventBusthrough one listener interface.Receives events published on anEventBuswhatever their listener interface; register withEventBus.addUntypedEventListener(UntypedEventListener).