Continue to use direct exchange routing v1

x-delayed-message exchange type does not use direct exchange routing v2
even when this feature flag is enabled.
Therefore, route directly via rabbit_router:match_routing_key/2 which corresponds
to "direct exchange routing v1".

Fix failing tests against rabbitmq-server master branch.

Fixes #199

Author: ansd

src/rabbit_exchange_type_delayed_message.erl

@@ -40,11 +40,21 @@ description() ->
     [{name, <<"x-delayed-message">>},
      {description, <<"Delayed Message Exchange.">>}].
 
-route(X, Delivery) ->
+route(X = #exchange{name = Name},
+      Delivery = #delivery{message = #basic_message{routing_keys = RKeys}}) ->
     case delay_message(X, Delivery) of
         nodelay ->
             %% route the message using proxy module
-            ?EXCHANGE(X):route(X, Delivery);
+            case ?EXCHANGE(X) of
+                rabbit_exchange_type_direct ->
+                    %% Exchange type x-delayed-message routes via "direct exchange routing v1"
+                    %% even when feature flag direct_exchange_routing_v2 is enabled because
+                    %% table rabbit_index_route only stores bindings whose source exchange
+                    %% is of type direct exchange.
+                    rabbit_router:match_routing_key(Name, RKeys);
+                Mod ->
+                    Mod:route(X, Delivery)
+            end;
         _ ->
             []
     end.

test/plugin_SUITE.erl

@@ -150,8 +150,6 @@ e2e_nodelay(Config) ->
     e2e_test0(Config, [0]).
 
 e2e_delay(Config) ->
-    %% message delay will be 0,
-    %% we are testing e2e without delays
     e2e_test0(Config, [500, 100, 300, 200, 100, 400]).
 
 e2e_test0(Config, Msgs) ->