Add "amq.match" builtin exchange; accept "headers" in exchange.declare; and

stub out routing implementation for headers exchanges.

1 files changed, 5 insertions, 0 deletions

diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl
index 925c335c..03478a4d 100644
--- a/src/rabbit_exchange.erl
+++ b/src/rabbit_exchange.erl
@@ -145,6 +145,8 @@ check_type(<<"direct">>) ->
     direct;
 check_type(<<"topic">>) ->
     topic;
+check_type(<<"headers">>) ->
+    headers;
 check_type(T) ->
     rabbit_misc:protocol_error(
       command_invalid, "invalid exchange type '~s'", [T]).
@@ -252,6 +254,9 @@ route(#exchange{name = Name, type = topic}, RoutingKey) ->
                         topic_matches(BindingKey, RoutingKey)]
       end);
 
+route(X = #exchange{type = headers}, _RoutingKey) ->
+    exit(headers_unimplemented);
+
 route(X = #exchange{type = fanout}, _) ->
     route_internal(X, '_');