Skip to content
This repository has been archived by the owner on Nov 18, 2020. It is now read-only.

Commit

Permalink
flesh out writer API for completeness
Browse files Browse the repository at this point in the history
  • Loading branch information
rade committed Nov 28, 2010
1 parent 8f42bba commit 8a653a8
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/amqp_channel.erl
Original file line number Diff line number Diff line change
Expand Up @@ -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),
Expand Down

0 comments on commit 8a653a8

Please sign in to comment.