Make the Erlang client work again.

deps/amqp_client/include/amqp_client.hrl

@@ -26,8 +26,11 @@
 -include_lib("rabbit_common/include/rabbit.hrl").
 -include_lib("rabbit_common/include/rabbit_framing.hrl").
 
+-define(PROTOCOL_VERSION_MAJOR, 0).
+-define(PROTOCOL_VERSION_MINOR, 8).
 -define(PROTOCOL_HEADER,
         <<"AMQP", 1, 1, ?PROTOCOL_VERSION_MAJOR, ?PROTOCOL_VERSION_MINOR>>).
+-define(PROTOCOL, amqp_0_8).
 
 -define(MAX_CHANNEL_NUMBER, 65535).
 

deps/amqp_client/rabbit_common.app.in

@@ -5,6 +5,8 @@
              rabbit_writer,
              rabbit_reader,
              rabbit_framing,
+             rabbit_framing_amqp_0_8,
+             rabbit_framing_amqp_0_9_1,
              rabbit_framing_channel,
              rabbit_basic,
              rabbit_binary_generator,

deps/amqp_client/src/amqp_channel_util.erl

@@ -56,8 +56,10 @@ open_channel(ProposedNumber, MaxChannel, Driver, StartArgs, Channels) ->
 %%---------------------------------------------------------------------------
 
 start_channel_infrastructure(network, ChannelNumber, {Sock, MainReader}) ->
-    FramingPid = rabbit_framing_channel:start_link(fun(X) -> X end, [self()]),
-    WriterPid = rabbit_writer:start_link(Sock, ChannelNumber, ?FRAME_MIN_SIZE),
+    FramingPid = rabbit_framing_channel:start_link(fun(X) -> X end, [self()],
+                                                  ?PROTOCOL),
+    WriterPid = rabbit_writer:start_link(Sock, ChannelNumber, ?FRAME_MIN_SIZE,
+                                        ?PROTOCOL),
     case MainReader of
         none ->
             ok;

deps/amqp_client/src/amqp_main_reader.erl

@@ -95,7 +95,7 @@ handle_inet_async({inet_async, Sock, _, Msg},
     end.
 
 handle_frame(Type, Channel, Payload, State) ->
-    case rabbit_reader:analyze_frame(Type, Payload) of
+    case rabbit_reader:analyze_frame(Type, Payload, ?PROTOCOL) of
         heartbeat when Channel /= 0 ->
             rabbit_misc:die(frame_error);
         trace when Channel /= 0 ->