Commanded.PubSub (Commanded v1.3.1) View Source
Use the pubsub configured for a Commanded application.
Link to this section Summary
Functions
Get the configured pub/sub adapter.
Broadcasts message on given topic.
Subscribes the caller to the PubSub adapter's topic.
Link to this section Types
Specs
application() :: Commanded.Application.t()
Specs
Link to this section Functions
Specs
adapter(application(), config()) :: {module(), config()}
Get the configured pub/sub adapter.
Defaults to a local pub/sub, restricted to running on a single node.
Broadcasts message on given topic.
topic- The topic to broadcast to, ie:"users:123"message- The payload of the broadcast
Subscribes the caller to the PubSub adapter's topic.