diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-05-20 17:46:44 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-05-20 17:46:44 +0100 |
| commit | 6087e31872aa8a03283ceef3bc8e03774bf54200 (patch) | |
| tree | a528df952d1e0fb99dd16c0bbcc830bdee6d9988 /src/rabbit_trace.erl | |
| parent | 8e01c9b20223d9ae91212bd6fe9e067153d0c124 (diff) | |
| download | rabbitmq-server-6087e31872aa8a03283ceef3bc8e03774bf54200.tar.gz | |
Fold publish and republish together.
Diffstat (limited to 'src/rabbit_trace.erl')
| -rw-r--r-- | src/rabbit_trace.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_trace.erl b/src/rabbit_trace.erl index e0681f15..cf8ee64c 100644 --- a/src/rabbit_trace.erl +++ b/src/rabbit_trace.erl @@ -27,7 +27,7 @@ -ifdef(use_specs). --type(state() :: rabbit_exchange:name() | 'none'). +-type(state() :: rabbit_types:exchange() | 'none'). -spec(init/1 :: (rabbit_types:vhost()) -> state()). -spec(tap_trace_in/2 :: (rabbit_types:basic_message(), state()) -> 'ok'). @@ -86,7 +86,7 @@ maybe_trace(#exchange{name = Name}, #basic_message{exchange_name = Name}, maybe_trace(X, Msg = #basic_message{content = #content{ payload_fragments_rev = PFR}}, RKPrefix, RKSuffix, Extra) -> - {ok, _, _} = rabbit_basic:republish( + {ok, _, _} = rabbit_basic:publish( X, <<RKPrefix/binary, ".", RKSuffix/binary>>, #'P_basic'{headers = msg_to_table(Msg) ++ Extra}, PFR), ok. |