diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-04-07 13:01:43 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-04-07 13:01:43 +0100 |
| commit | fd05e61ba433b0545dd31b0c4e233caad7be200d (patch) | |
| tree | 845c08cce5a025848117295546ca6e3e91c007cc | |
| parent | 8f977fc47b04f9a558908ad7433c8a229ec64cc6 (diff) | |
| download | rabbitmq-server-git-fd05e61ba433b0545dd31b0c4e233caad7be200d.tar.gz | |
Don't expose queue message ID.
| -rw-r--r-- | src/rabbit_log.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_log.erl b/src/rabbit_log.erl index 9dbf906a73..aa2e990cd7 100644 --- a/src/rabbit_log.erl +++ b/src/rabbit_log.erl @@ -93,7 +93,7 @@ tap_trace_in(Message = #basic_message{exchange_name = #resource{ <<"publish">>, XNameBin, EncodedMetadata, Payload) end). -tap_trace_out({#resource{name = QNameBin}, _QPid, QMsgId, Redelivered, +tap_trace_out({#resource{name = QNameBin}, _QPid, _QMsgId, Redelivered, Message = #basic_message{exchange_name = #resource{ virtual_host = VHostBin, name = XNameBin}}}, @@ -104,9 +104,8 @@ tap_trace_out({#resource{name = QNameBin}, _QPid, QMsgId, Redelivered, fun (TraceExchangeBin) -> RedeliveredNum = case Redelivered of true -> 1; false -> 0 end, {EncodedMetadata, Payload} = message_to_table(Message), - Fields0 = [{<<"delivery_tag">>, signedint, DeliveryTag}, %% FIXME later - {<<"queue_msg_number">>, signedint, QMsgId}, - {<<"redelivered">>, signedint, RedeliveredNum}] + Fields0 = [{<<"delivery_tag">>, signedint, DeliveryTag}, %% FIXME later + {<<"redelivered">>, signedint, RedeliveredNum}] ++ EncodedMetadata, Fields = case ConsumerTagOrNone of none -> |