RabbitMqTransportOptions

Defined in: types.ts:4

Options for creating a RabbitMQ-backed pubsub transport.

Properties

defaultSource?

optional defaultSource?: string

Defined in: types.ts:22

Default CloudEvent source for publishers using this transport.

---

exchange?

optional exchange?: string

Defined in: types.ts:8

Durable topic exchange used for normal event delivery. Defaults to protoutil.pubsub.

---

interceptors?

optional interceptors?: PubSubInterceptor[]

Defined in: types.ts:24

Optional interceptors for transport operations.

---

publishTimeoutMs?

optional publishTimeoutMs?: number

Defined in: types.ts:12

Optional timeout for broker publish confirms in milliseconds.

---

queuePrefix?

optional queuePrefix?: string

Defined in: types.ts:10

Durable queue prefix used for subscription queues. Defaults to protoutil.pubsub.queue.

---

scheduler?

optional scheduler?: PubSubScheduler

Defined in: types.ts:20

Optional scheduler used for durable notBefore publish and delayed retry.

Immediate publish/subscribe does not require a scheduler. If a publish call provides notBefore, or a handler returns ctx.retry({ delay }), the transport throws unless a scheduler was supplied.

---

signal?

optional signal?: AbortSignal

Defined in: types.ts:26

Optional signal that closes this transport when aborted.

---

url

url: string

Defined in: types.ts:6

AMQP connection URL.