Being more specific in the response for Channel#get in amqplib (#16895)

This commit is contained in:
Anthony Rosequist
2017-06-01 13:43:18 -05:00
committed by Mohamed Hegazy
parent 3ca61c9879
commit c2dbda28dc
2 changed files with 2 additions and 2 deletions

View File

@@ -34,7 +34,7 @@ export interface Channel extends events.EventEmitter {
consume(queue: string, onMessage: (msg: Message) => any, options?: Options.Consume, callback?: (err: any, ok: Replies.Consume) => void): void;
cancel(consumerTag: string, callback?: (err: any, ok: Replies.Empty) => void): void;
get(queue: string, options?: Options.Get, callback?: (err: any, ok: Message | boolean) => void): void;
get(queue: string, options?: Options.Get, callback?: (err: any, ok: Message | false) => void): void;
ack(message: Message, allUpTo?: boolean): void;
ackAll(): void;

View File

@@ -42,7 +42,7 @@ export interface Channel extends events.EventEmitter {
consume(queue: string, onMessage: (msg: Message) => any, options?: Options.Consume): Promise<Replies.Consume>;
cancel(consumerTag: string): Promise<Replies.Empty>;
get(queue: string, options?: Options.Get): Promise<Message | boolean>;
get(queue: string, options?: Options.Get): Promise<Message | false>;
ack(message: Message, allUpTo?: boolean): void;
ackAll(): void;