summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_framing_channel.erl9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/rabbit_framing_channel.erl b/src/rabbit_framing_channel.erl
index 8eabf42bdc..490435835d 100644
--- a/src/rabbit_framing_channel.erl
+++ b/src/rabbit_framing_channel.erl
@@ -82,7 +82,14 @@ mainloop(ChannelPid) ->
end,
?MODULE:mainloop(ChannelPid).
-%% Handle 0-8 version of basic.consume, which doesn't have a table on the end
+%% Handle 0-8 version of channel.tune-ok. In 0-9-1 it gained a longstr
+%% "deprecated_channel_id".
+decode_method_fields('channel.tune_ok', FieldsBin) ->
+ Len = 0,
+ rabbit_framing:decode_method_fields(
+ 'channel.tune_ok', <<FieldsBin/binary, Len:32/unsigned>>);
+%% Handle 0-8 version of basic.consume. In 0-9-1 it gained a table
+%% "filter".
decode_method_fields('basic.consume', FieldsBin) ->
T = rabbit_binary_generator:generate_table([]),
TLen = size(T),