When feature flag message_containers is enabled, setting ``` message_interceptors.incoming.set_header_timestamp ``` wasn't respected anymore when a message is published via MQTT to a stream and subsequently consumed via AMQP 0.9.1. This commit ensures that AMQP 0.9.1 header timestamp_in_ms will be set. Note that we must not modify the AMQP 1.0 properties section when messages are received via AMQP 1.0 and consumed via AMQP 1.0. Also, message annoation keys not starting with "x-" are reserved. |
||
---|---|---|
.. | ||
rabbit_assert.hrl | ||
rabbit_mgmt_test.hrl |