diff options
| author | Michael Klishin <klishinm@vmware.com> | 2021-11-14 21:59:12 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-11-14 21:59:12 +0300 |
| commit | 01f68b80c9b259ba488ee2cfce073e31cc8a91d0 (patch) | |
| tree | 386f69e5da04f9192c04c57996dc8daeed3d45d5 | |
| parent | 38982e2c672aeb203eca508cc9691586e1fb8b8b (diff) | |
| parent | b4f39031f6cf2dadf522a56507364d24d0faf200 (diff) | |
| download | rabbitmq-server-git-01f68b80c9b259ba488ee2cfce073e31cc8a91d0.tar.gz | |
Merge pull request #3723 from wrobell/rabbitmq-streams-doc-protocol-deliver-fix
Fix description of "deliver" command in RabbitMQ Streams protocol documentation
| -rw-r--r-- | deps/rabbitmq_stream/docs/PROTOCOL.adoc | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/docs/PROTOCOL.adoc b/deps/rabbitmq_stream/docs/PROTOCOL.adoc index 26ab420199..34786dad30 100644 --- a/deps/rabbitmq_stream/docs/PROTOCOL.adoc +++ b/deps/rabbitmq_stream/docs/PROTOCOL.adoc @@ -327,17 +327,21 @@ Subscribe => Key Version CorrelationId SubscriptionId Stream OffsetSpecification ``` Deliver => Key Version SubscriptionId OsirisChunk Key => uint16 // 0x0008 - Version => uint32 + Version => uint16 SubscriptionId => uint8 OsirisChunk => MagicVersion NumEntries NumRecords Epoch ChunkFirstOffset ChunkCrc DataLength Messages MagicVersion => int8 + ChunkType => int8 // 0: user, 1: tracking delta, 2: tracking snapshot NumEntries => uint16 NumRecords => uint32 + Timestamp => int64 // in milliseconds, since epoch Epoch => uint64 ChunkFirstOffset => uint64 ChunkCrc => int32 DataLength => uint32 - Messages => [Message] // no int32 for the size for this array + TrailerLength => uint32 + Reserved => unit32 // unused 4 bytes + Messages => [Message] // no int32 for the size for this array; the size is defined by NumEntries field above Message => EntryTypeAndSize Data => bytes ``` |