diff --git a/src/amqp-channel.ts b/src/amqp-channel.ts index ab9438b..ac65961 100644 --- a/src/amqp-channel.ts +++ b/src/amqp-channel.ts @@ -743,11 +743,9 @@ export class AMQPChannel { private sendRpc(frame: AMQPView, frameSize: number): Promise { return new Promise((resolve, reject) => { this.rpcQueue = this.rpcQueue.then(() => { + this.resolveRPC = resolve + this.rejectRPC = reject this.connection.send(new Uint8Array(frame.buffer, 0, frameSize)) - .then(() => { - this.resolveRPC = resolve - this.rejectRPC = reject - }) .catch(reject) }) })