diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-05-10 16:33:46 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-05-10 16:33:46 +0100 |
| commit | 7e3713e13764ccba3e9edc76066f178981c771bf (patch) | |
| tree | cfbffa96b1007cc139759563d31de7af0452a445 /src/rabbit_channel.erl | |
| parent | 8dff232b17a8a50a617df3b4d4ccca3a890365c3 (diff) | |
| parent | 8d6b67929bf5dcfbfad62c3e1fd232056a99c3f5 (diff) | |
| download | rabbitmq-server-7e3713e13764ccba3e9edc76066f178981c771bf.tar.gz | |
Merge bug20589 into default
Diffstat (limited to 'src/rabbit_channel.erl')
| -rw-r--r-- | src/rabbit_channel.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 083c5963..f0788862 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -281,6 +281,7 @@ handle_cast({deliver, ConsumerTag, AckRequired, true -> deliver; false -> deliver_no_ack end, State), + rabbit_trace:tap_trace_out(Msg), noreply(State1#ch{next_tag = DeliveryTag + 1}); handle_cast(emit_stats, State = #ch{stats_timer = StatsTimer}) -> @@ -607,6 +608,7 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, end, case rabbit_basic:message(ExchangeName, RoutingKey, DecodedContent) of {ok, Message} -> + rabbit_trace:tap_trace_in(Message), {RoutingRes, DeliveredQPids} = rabbit_exchange:publish( Exchange, @@ -675,6 +677,7 @@ handle_method(#'basic.get'{queue = QueueNameBin, true -> get_no_ack; false -> get end, State), + rabbit_trace:tap_trace_out(Msg), ok = rabbit_writer:send_command( WriterPid, #'basic.get_ok'{delivery_tag = DeliveryTag, |