diff options
Diffstat (limited to 'src/rabbit_exchange_type_headers.erl')
| -rw-r--r-- | src/rabbit_exchange_type_headers.erl | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/src/rabbit_exchange_type_headers.erl b/src/rabbit_exchange_type_headers.erl index 0a59a175..7edc6f7b 100644 --- a/src/rabbit_exchange_type_headers.erl +++ b/src/rabbit_exchange_type_headers.erl @@ -57,16 +57,13 @@ description() -> {description, <<"AMQP headers exchange, as per the AMQP specification">>}]. publish(#exchange{name = Name}, - Delivery = #delivery{message = #basic_message{content = Content}}) -> + #delivery{message = #basic_message{content = Content}}) -> Headers = case (Content#content.properties)#'P_basic'.headers of undefined -> []; H -> rabbit_misc:sort_field_table(H) end, - rabbit_router:deliver(rabbit_router:match_bindings( - Name, fun (#binding{args = Spec}) -> - headers_match(Spec, Headers) - end), - Delivery). + rabbit_router:match_bindings( + Name, fun (#binding{args = Spec}) -> headers_match(Spec, Headers) end). default_headers_match_kind() -> all. |