View Source Commanded.PubSub (Commanded v1.4.1)
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
@type application() :: Commanded.Application.t()
Link to this section Functions
@spec 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.