notice

This is unreleased documentation for Rasa Open Source Documentation Master/Unreleased version.
For the latest released documentation, see the latest version (2.0.x).

Version: Master/Unreleased

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.