cap-nodejs

CAP Node.js API

---

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

Class: ServiceBusSubscriber

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-subscriber.ts:30

Implements

• SubscriberPort

Constructors

Constructor

new ServiceBusSubscriber(client, configOrTopicPrefix?, subscriptionPrefix?, logger?): ServiceBusSubscriber

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-subscriber.ts:38

Parameters

client

ServiceBusClient

configOrTopicPrefix?

string | ServiceBusOptions

subscriptionPrefix?

string

logger?

CapLogger

Returns

ServiceBusSubscriber

Methods

close()

close(): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-subscriber.ts:376

Returns

Promise<void>

Implementation of

SubscriberPort.close

---

consume()

consume(topic, group, onMessage): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-subscriber.ts:99

Parameters

topic

string

group

string

onMessage

CapMessageHandler

Returns

Promise<void>

Implementation of

SubscriberPort.consume

---

initialize()?

optional initialize(options?): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-subscriber.ts:57

Parameters

options?

autoInit?

boolean

createQueues?

boolean

Returns

Promise<void>

Implementation of

SubscriberPort.initialize

---

onModuleDestroy()

onModuleDestroy(): Promise<void>

Defined in: cap-transport-azure-servicebus/src/transport/servicebus-subscriber.ts:372

Returns

Promise<void>

This site is open source. Improve this page.