View Source Commanded.PubSub.LocalPubSub (Commanded v1.4.6)

Local pub/sub adapter, restricted to a single node, using Elixir's Registry.

You can configure this adapter in your environment config file:

# `config/config.exs`
config :my_app, MyApp.Application, pubsub: :local

This adapter will be used by default when none is specified in config.

Summary

Functions

broadcast(adapter_meta, topic, message)

Broadcasts message on given topic.

child_spec(application, config)

Start a Registry for local pub/sub.

list(adapter_meta, topic)

List tracked terms and associated PIDs for a given topic.

subscribe(adapter_meta, topic)

Subscribes the caller to the topic.

track(adapter_meta, topic, key)

Track the current process under the given topic, uniquely identified by key.

Functions

Link to this function

broadcast(adapter_meta, topic, message)

View Source

Broadcasts message on given topic.

Link to this function

child_spec(application, config)

View Source

Start a Registry for local pub/sub.

Link to this function

list(adapter_meta, topic)

View Source

List tracked terms and associated PIDs for a given topic.

Link to this function

subscribe(adapter_meta, topic)

View Source

Subscribes the caller to the topic.

Link to this function

track(adapter_meta, topic, key)

View Source

Track the current process under the given topic, uniquely identified by key.