Message Broker

Development

Quick Start

npm install @morgan-stanley/message-broker
import {
    messageBroker,
    IMessageBroker
} from '@morgan-stanley/message-broker'

interface IContracts {
    myChannel: {
        payload: string
    }
}

const broker: IMessageBroker<IContracts>
    = messageBroker<IContracts>();

broker.get('myChannel').subscribe(message => {
    console.log(message.payload)
});

broker.create('myChannel').publish({
    payload: 'My first message using the MessageBroker!'
});

Dependency Injection

The MessageBroker class is decorated with @Injectable from @morgan-stanley/needle. This means that it can be constructed by different DI frameworks. For more information please refer to the documentation for the Needle framework.