cap-nodejs

CAP Node.js API

CAP Node.js API / cap-transport-azure-servicebus/src / ServiceBusPublisher

Class: ServiceBusPublisher

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-publisher.ts:17

Azure Service Bus implementation of PublisherPort. Sends messages to Service Bus topics.

Implements

Constructors

Constructor

new ServiceBusPublisher(client, config, logger?): ServiceBusPublisher

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-publisher.ts:20

Parameters

client

ServiceBusClient

config

ServiceBusOptions

logger?

CapLogger

Returns

ServiceBusPublisher

Methods

close()

close(): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-publisher.ts:85

Returns

Promise<void>

emit()

emit(topic, payload, headers?, metadata?): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-publisher.ts:53

Parameters

topic

string

payload

unknown

headers?

CapHeaders

metadata?

PublishMetadata

Returns

Promise<void>

Implementation of

PublisherPort.emit

initialize()?

optional initialize(options?): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-publisher.ts:26

Parameters

options?
autoInit?

boolean

createQueues?

boolean

Returns

Promise<void>

Implementation of

PublisherPort.initialize

onModuleDestroy()

onModuleDestroy(): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-publisher.ts:97

Returns

Promise<void>

This site is open source. Improve this page.