From 6d2025204d3adc050f916c2c116c9ac8db36114c Mon Sep 17 00:00:00 2001 From: Jason Walton Date: Wed, 13 Apr 2022 10:15:48 -0400 Subject: [PATCH] fix(types): Export PublishOptions type. --- src/ChannelWrapper.ts | 2 +- src/index.ts | 15 +++++++++++++++ 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/src/ChannelWrapper.ts b/src/ChannelWrapper.ts index 65916dd..63a83bb 100644 --- a/src/ChannelWrapper.ts +++ b/src/ChannelWrapper.ts @@ -64,7 +64,7 @@ interface SendToQueueMessage { isTimedout: boolean; } -interface PublishOptions extends Options.Publish { +export interface PublishOptions extends Options.Publish { /** Message will be rejected after timeout ms */ timeout?: number; } diff --git a/src/index.ts b/src/index.ts index 3281ba8..dd1d21a 100644 --- a/src/index.ts +++ b/src/index.ts @@ -1,8 +1,10 @@ +/* eslint-disable @typescript-eslint/no-namespace */ import AmqpConnectionManager, { AmqpConnectionManagerOptions, ConnectionUrl, IAmqpConnectionManager, } from './AmqpConnectionManager.js'; +import { PublishOptions } from './ChannelWrapper.js'; export type { AmqpConnectionManagerOptions, @@ -16,6 +18,19 @@ export type { Channel, } from './ChannelWrapper.js'; +import { Options as AmqpLibOptions } from 'amqplib'; + +export namespace Options { + export type Connect = AmqpLibOptions.Connect; + export type AssertQueue = AmqpLibOptions.AssertQueue; + export type DeleteQueue = AmqpLibOptions.DeleteQueue; + export type AssertExchange = AmqpLibOptions.AssertExchange; + export type DeleteExchange = AmqpLibOptions.DeleteExchange; + export type Publish = PublishOptions; + export type Consume = AmqpLibOptions.Consume; + export type Get = AmqpLibOptions.Get; +} + export function connect( urls: ConnectionUrl | ConnectionUrl[] | undefined | null, options?: AmqpConnectionManagerOptions