Module msgbus

A common in-memory MessageBus for loosely coupled message passing patterns.

Modules

database

handler

Message handler functionality for the message bus system.

listener

stubs

switchboard

Structs

BusMessage

Represents a bus message including a topic and payload.

MessageBus

A generic message bus to facilitate various messaging patterns.

MessageBusWrapper

Subscription

Represents a subscription to a particular topic.

Constants

CLOSE_TOPIC

Functions

deregister

Deregisters the given handler for the endpoint address.

get_message_bus

is_matching

Match a topic and a string pattern pattern can contains - ‘*’ - match 0 or more characters after this ‘?’ - match any character once ‘a-z’ - match the specific character

is_subscribed

publish

Publish a message to a topic.

register

Registers the given handler for the endpoint address.

send

set_message_bus

subscribe

Subscribes the given handler to the topic.

subscriptions_count

unsubscribe

Unsubscribes the given handler from the topic.