From beff3ac6b2e7dd8fef6d25759f67435254d0f89d Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Mon, 11 Aug 2014 18:05:32 +0400 Subject: [PATCH] ChPid => DeliveryCtx --- src/amqp_selective_consumer.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/amqp_selective_consumer.erl b/src/amqp_selective_consumer.erl index a06118ee..a7bd9060 100644 --- a/src/amqp_selective_consumer.erl +++ b/src/amqp_selective_consumer.erl @@ -221,9 +221,9 @@ deliver(Method, Message, State) -> true -> {Method, Message} end, deliver_to_consumer_or_die(Method, Combined, State). -deliver(Method, Message, ChPid, State) -> +deliver(Method, Message, DeliveryCtx, State) -> Combined = if Message =:= undefined -> Method; - true -> {Method, Message, ChPid} + true -> {Method, Message, DeliveryCtx} end, deliver_to_consumer_or_die(Method, Combined, State).