Skip to content

Commit

Permalink
fix(rabbitmq): add await to publish on reply-to
Browse files Browse the repository at this point in the history
add await to publish on reply channel so error can be handled by error handler
  • Loading branch information
arjenvdhave authored Jun 2, 2021
1 parent 0b68e7b commit 59c57ca
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion packages/rabbitmq/src/amqp/connection.ts
Original file line number Diff line number Diff line change
Expand Up @@ -354,7 +354,7 @@ export class AmqpConnection {

const { replyTo, correlationId } = msg.properties;
if (replyTo) {
this.publish('', replyTo, response, { correlationId });
await this.publish('', replyTo, response, { correlationId });
}
channel.ack(msg);
} catch (e) {
Expand Down

0 comments on commit 59c57ca

Please sign in to comment.