diff --git a/types/bunnymq/index.d.ts b/types/bunnymq/index.d.ts index c4c0a770e1..1adb125697 100644 --- a/types/bunnymq/index.d.ts +++ b/types/bunnymq/index.d.ts @@ -17,8 +17,8 @@ declare namespace bunnymq { /** * Handle messages from a named queue. * - * @param {string} queue A named queue. - * @param {ConsumerCallback} callback A callback. + * @param queue A named queue. + * @param callback A callback. */ consume(queue: string, callback: ConsumerCallback): void; } @@ -31,16 +31,15 @@ declare namespace bunnymq { /** * Subscriber to handle messages from a named queue. * - * @param {string} queue A named queue. - * @param {ConsumerCallback} callback A callback. + * @param queue A named queue. + * @param callback A callback. */ subscribe(queueName: string, callback: ConsumerCallback): void; /** * Publisher to send messages to a named queue. * - * @type {Producer} - * @return {Promise} The consumer response. + * @return The consumer response. */ publish(queueName: string, message: any, options?: ProducerOptions): Promise; } @@ -61,14 +60,12 @@ declare namespace bunnymq { /** * Number of fetched messages at once on the channel. * - * @type {number} */ prefetch?: number; /** * Requeue put back message into the broker if consumer crashes/trigger exception. * - * @type {boolean} */ requeue?: boolean; rpcTimeout?: number; @@ -80,9 +77,9 @@ declare namespace bunnymq { /** * Send messages to a named queue. * - * @param {string} queue A named queue. - * @param {any} message A message. - * @return {Promise} The consumer response. + * @param queue A named queue. + * @param message A message. + * @return The consumer response. */ produce(queue: string, message: any, options?: ProducerOptions): Promise; }