Class MessageBus

Index

Constructors

Methods

clear getSubscriberCount publish subscribe unsubscribe

Constructors

constructor

new MessageBus(): MessageBus

Returns MessageBus

Methods

clear

clear(): void
Clear all subscriptions

Returns void
- Defined in embedded32-core/src/messaging/MessageBus.ts:57

getSubscriberCount

getSubscriberCount(topic: string): number
Get number of subscribers for a topic
Parameters
- topic: string
Returns number
- Defined in embedded32-core/src/messaging/MessageBus.ts:50

publish

publish(topic: string, payload: any, source?: string): Promise<void>
Publish a message to a topic
Parameters
- topic: string
- payload: any
- Optionalsource: string
Returns Promise<void>
- Defined in embedded32-core/src/messaging/MessageBus.ts:32

subscribe(topic: string, handler: MessageHandler): void
Subscribe to a topic
Parameters
- topic: string
- handler: MessageHandler
Returns void
- Defined in embedded32-core/src/messaging/MessageBus.ts:9

unsubscribe

unsubscribe(topic: string, handler: MessageHandler): void
Unsubscribe from a topic
Parameters
- topic: string
- handler: MessageHandler
Returns void
- Defined in embedded32-core/src/messaging/MessageBus.ts:19