RabbitMqTransportOptions
Options for creating a RabbitMQ-backed pubsub transport.
Properties
Section titled “Properties”defaultSource?
Section titled “defaultSource?”
optionaldefaultSource?:string
Default CloudEvent source for publishers using this transport.
exchange?
Section titled “exchange?”
optionalexchange?:string
Durable topic exchange used for normal event delivery. Defaults to protoutil.pubsub.
interceptors?
Section titled “interceptors?”
optionalinterceptors?:PubSubInterceptor[]
Optional interceptors for transport operations.
publishTimeoutMs?
Section titled “publishTimeoutMs?”
optionalpublishTimeoutMs?:number
Optional timeout for broker publish confirms in milliseconds.
queuePrefix?
Section titled “queuePrefix?”
optionalqueuePrefix?:string
Durable queue prefix used for subscription queues. Defaults to protoutil.pubsub.queue.
scheduler?
Section titled “scheduler?”
optionalscheduler?:PubSubScheduler
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?
Section titled “signal?”
optionalsignal?:AbortSignal
Optional signal that closes this transport when aborted.
url:
string
AMQP connection URL.