From 8a653a8f849ac51cca1566a8488c37e87e55b5f3 Mon Sep 17 00:00:00 2001 From: Matthias Radestock Date: Sun, 28 Nov 2010 11:07:03 +0000 Subject: [PATCH] flesh out writer API for completeness --- src/amqp_channel.erl | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/amqp_channel.erl b/src/amqp_channel.erl index 53a87cbb..c40e4279 100644 --- a/src/amqp_channel.erl +++ b/src/amqp_channel.erl @@ -573,7 +573,12 @@ handle_info({send_command, Method}, State) -> handle_info({send_command, Method, Content}, State) -> handle_method(Method, Content, State); -%% This handles the delivery of a message from a direct channel +%% These callbacks handles the delivery of a message from a direct channel +%% @private +handle_info({send_command_and_notify, Q, ChPid, Method}, State) -> + handle_method(Method, none, State), + rabbit_amqqueue:notify_sent(Q, ChPid), + {noreply, State}; %% @private handle_info({send_command_and_notify, Q, ChPid, Method, Content}, State) -> handle_method(Method, Content, State),