diff --git a/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session.erl b/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session.erl index 468f0880f36b..708136679bbd 100644 --- a/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session.erl +++ b/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_session.erl @@ -950,7 +950,8 @@ handle_deliver(ConsumerTag, AckRequired, batchable = false}, Mc1 = mc:convert(mc_amqp, Mc0), Mc = mc:set_annotation(redelivered, Redelivered, Mc1), - Sections = mc:serialize(Mc), + Sections0 = mc:protocol_state(Mc), + Sections = mc_amqp:serialize(Sections0), ?DEBUG("Outbound content:~n ~tp", [[amqp10_framing:pprint(Section) || Section <- amqp10_framing:decode_bin(iolist_to_binary(Sections))]]),