Version: 2.0.x

rasa.core.brokers.broker

EventBroker Objects

class EventBroker()

Base class for any event broker implementation.

create

| @staticmethod
| create(obj: Union["EventBroker", EndpointConfig, None]) -> Optional["EventBroker"]

Factory to create an event broker.

publish

| publish(event: Dict[Text, Any]) -> None

Publishes a json-formatted Rasa Core event into an event queue.

is_ready

| is_ready() -> bool

Determine whether or not the event broker is ready.

Returns:

True by default, but this may be overridden by subclasses.

close

| close() -> None

Close the connection to an event broker.