cap-nodejs

CAP Node.js API

---

CAP Node.js API / cap-transport-rabbitmq/src / RabbitMqSubscriber

Class: RabbitMqSubscriber

Defined in: cap-transport-rabbitmq/src/rabbitmq-subscriber.ts:44

Implements

• SubscriberPort

Constructors

Constructor

new RabbitMqSubscriber(options?): RabbitMqSubscriber

Defined in: cap-transport-rabbitmq/src/rabbitmq-subscriber.ts:86

Parameters

options?

RabbitMqOptions = {}

Returns

RabbitMqSubscriber

Methods

close()

close(): Promise<void>

Defined in: cap-transport-rabbitmq/src/rabbitmq-subscriber.ts:129

Returns

Promise<void>

Implementation of

SubscriberPort.close

---

consume()

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

Defined in: cap-transport-rabbitmq/src/rabbitmq-subscriber.ts:104

Parameters

topic

string

group

string

handler

CapHandler

Returns

Promise<void>

Implementation of

SubscriberPort.consume

---

dispatchDelivery()

dispatchDelivery(group, message): Promise<void>

Defined in: cap-transport-rabbitmq/src/rabbitmq-subscriber.ts:254

Adapter delivery boundary, exposed for controlled broker harnesses.

Parameters

group

string

message

ConsumeMessage | null

Returns

Promise<void>

---

initialize()

initialize(_options?): Promise<void>

Defined in: cap-transport-rabbitmq/src/rabbitmq-subscriber.ts:90

Parameters

_options?

InitOptions

Returns

Promise<void>

Implementation of

SubscriberPort.initialize

This site is open source. Improve this page.