@imaness/bus-azure-service-bus
An Azure Service Bus queue adapter for @node-ts/bus
Installation
Install packages and their dependencies
npm i @imaness/bus-azure-service-bus @node-ts/bus-coreOnce installed, configure Bus to use this transport during initialization:
import { Bus } from '@node-ts/bus-core'
import { ServiceBusTransport, ServiceBusTransportConfiguration } from '@imaness/bus-azure-service-bus'
// For Using Service Bus Queue
const sbQueueConfiguration: ServiceBusTransportConfiguration = {
queueName: {Queue Name},
serviceBusClient: new ServiceBusClient(),
}
const sbQueueTransport = new ServiceBusTransport(sbConfiguration)
// For Using Service Bus Topic
const sbTopicSubscriptionConfiguration: ServiceBusTransportConfiguration = {
topicName: {Topic Name},
subscriptionName: {Subscription Name},
serviceBusClient: new ServiceBusClient()
}
const sbTopicTransport = new ServiceBusTransport(sbConfiguration)
// Configure Bus to use Azure Service Bus Queue as a transport
const run = async () => {
await Bus
.configure()
.withTransport({ sbQueueTransport or sbTopicTransport })
.initialize()
}
run.catch(console.error)Mapping of ApplicationProperties to Attributes and StickyAttributes
Azure Service Bus supports Message Properties.
In order for you to map it to Attributes or StickyAttributes you need to add key prefix of either attributes or stickyAttributes. Those key that are not have the said prefixes will be considered as attributes.