Package com.tnsai.coordination.choreography

Class ChoreographyEventBus

java.lang.Object

com.tnsai.coordination.choreography.ChoreographyEventBus

public final class ChoreographyEventBus
extends Object

Event-driven bus for choreography coordination. Supports topic-based publish/subscribe with event history.

Example usage:

 ChoreographyEventBus bus = new ChoreographyEventBus();
 bus.subscribe("order.placed", (name, event) -> processOrder(event));
 bus.publish(ChoreographyEvent.of("order.placed", "system", "order-123"));
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ChoreographyEventBus.ChoreographyEvent	An event published on the choreography bus.

Constructor Summary

Constructors

Constructor	Description
ChoreographyEventBus()
ChoreographyEventBus(int maxHistory)

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears all subscribers and history.
void	close()	Closes the event bus, rejecting further publishes.
int	eventCount()	Returns the number of events in history.
List<ChoreographyEventBus.ChoreographyEvent>	eventsOf(String eventName)	Returns all events with a specific name.
boolean	hasEvent(String eventName)	Checks if a specific event name was ever published.
List<ChoreographyEventBus.ChoreographyEvent>	history()	Returns a copy of the event history.
boolean	isClosed()	Returns whether the bus is closed.
void	publish(ChoreographyEventBus.ChoreographyEvent event)	Publishes an event to all subscribers of that event name.
void	subscribe(String eventName, BiConsumer<String,ChoreographyEventBus.ChoreographyEvent> handler)	Subscribes a handler to events with the given name.

Methods inherited from class java.lang.Object

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

Constructor Details

ChoreographyEventBus

public ChoreographyEventBus()

ChoreographyEventBus

public ChoreographyEventBus(int maxHistory)

Method Details

subscribe

public void subscribe(String eventName,
 BiConsumer<String,ChoreographyEventBus.ChoreographyEvent> handler)

Subscribes a handler to events with the given name.

publish

public void publish(ChoreographyEventBus.ChoreographyEvent event)

Publishes an event to all subscribers of that event name.

history

public List<ChoreographyEventBus.ChoreographyEvent> history()

Returns a copy of the event history.

eventCount

public int eventCount()

Returns the number of events in history.

hasEvent

public boolean hasEvent(String eventName)

Checks if a specific event name was ever published.

eventsOf

public List<ChoreographyEventBus.ChoreographyEvent> eventsOf(String eventName)

Returns all events with a specific name.

clear

public void clear()

Clears all subscribers and history.

close

public void close()

Closes the event bus, rejecting further publishes.

isClosed

public boolean isClosed()

Returns whether the bus is closed.