export interface PublishOptions extends Options.Publish {
/** Message will be rejected after timeout ms */
timeout?: number;
}
export interface ConsumerOptions extends amqplib.Options.Consume {
prefetch?: number;
}
It seems the amqp options is not extended :(
It seems the amqp options is not extended :(