diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2020-10-28 15:19:20 +0000 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2020-10-28 15:19:20 +0000 |
| commit | 4c7a176d22cd271e6bc1bdbcd73bc0eb8c943551 (patch) | |
| tree | bac71a11f2bd97115b10ce88d2e3c94be09ea621 | |
| parent | d9a1355dfac8b8426608e43605291e3766f0977c (diff) | |
| download | rabbitmq-server-git-stream-protocol-interoperability.tar.gz | |
Add missing 'byte' type to amqp 0.9.1 record conversionstream-protocol-interoperability
The x-mqtt-publish-qos argument is a 'byte', without this MQTT can't publish
to stream queues
| -rw-r--r-- | src/rabbit_msg_record.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_msg_record.erl b/src/rabbit_msg_record.erl index e76c3f8dc4..3ebe14cb9f 100644 --- a/src/rabbit_msg_record.erl +++ b/src/rabbit_msg_record.erl @@ -346,7 +346,8 @@ from_091(double, V) -> {double, V}; from_091(float, V) -> {float, V}; from_091(bool, V) -> {boolean, V}; from_091(binary, V) -> {binary, V}; -from_091(timestamp, V) -> {timestamp, V * 1000}. +from_091(timestamp, V) -> {timestamp, V * 1000}; +from_091(byte, V) -> {byte, V}. % convert_header(signedint, V) -> [$I, <<V:32/signed>>]; % convert_header(decimal, V) -> {Before, After} = V, |