diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-03-30 09:45:29 +0200 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-04-08 12:02:51 +0300 |
| commit | 5eb6f561dbf6581ae6dcdee5321d7dfe804522bf (patch) | |
| tree | 8044e216399f46da25b283ecfdaf71be16016a19 | |
| parent | fe410938fcc31c6150a8bcb4e0ca47e04645173f (diff) | |
| download | rabbitmq-server-git-5eb6f561dbf6581ae6dcdee5321d7dfe804522bf.tar.gz | |
Handle 4 reserved bytes in osiris chunk
References rabbitmq/osiris#22
| -rw-r--r-- | deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl b/deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl index 176fcf71fc..8dbc1de4b0 100644 --- a/deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl +++ b/deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl @@ -435,7 +435,7 @@ test_subscribe(S, SubscriptionId, Stream) -> test_deliver(S, Rest, SubscriptionId, Body) -> BodySize = byte_size(Body), Frame = read_frame(S, Rest), - <<58:32, + <<62:32, ?REQUEST:1, ?COMMAND_DELIVER:15, ?VERSION_1:16, @@ -451,6 +451,7 @@ test_deliver(S, Rest, SubscriptionId, Body) -> _Crc:32, _DataLength:32, _TrailerLength:32, + _ReservedBytes:32, 0:1, BodySize:31/unsigned, Body/binary>> = |