diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-09-03 13:46:57 +0200 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-09-03 13:46:57 +0200 |
| commit | c25d89d67a77a2011bc4d77fee9ed62d4e6b91c9 (patch) | |
| tree | 0265ecbf1487a1c9505c23d3f921836959422f2b | |
| parent | 21d9aea96cec88c8bb9d62c5d40433b9675c62f4 (diff) | |
| download | rabbitmq-server-git-c25d89d67a77a2011bc4d77fee9ed62d4e6b91c9.tar.gz | |
Adapt test to additional chunk type field in chunk
| -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 62a581349d..26315d7e10 100644 --- a/deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl +++ b/deps/rabbitmq_stream/test/rabbit_stream_SUITE.erl @@ -217,7 +217,8 @@ test_subscribe(S, SubscriptionId, Stream) -> test_deliver(S, Rest, SubscriptionId, Body) -> BodySize = byte_size(Body), Frame = read_frame(S, Rest), - <<53:32, ?COMMAND_DELIVER:16, ?VERSION_0:16, SubscriptionId:8, 5:4/unsigned, 0:4/unsigned, 1:16, 1:32, + <<54:32, ?COMMAND_DELIVER:16, ?VERSION_0:16, SubscriptionId:8, 5:4/unsigned, 0:4/unsigned, 0:8, + 1:16, 1:32, _Timestamp:64, _Epoch:64, 0:64, _Crc:32, _DataLength:32, 0:1, BodySize:31/unsigned, Body/binary>> = Frame. |