diff options
Diffstat (limited to 'weed/mq/segment/message_serde_test.go')
| -rw-r--r-- | weed/mq/segment/message_serde_test.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/mq/segment/message_serde_test.go b/weed/mq/segment/message_serde_test.go index c65bffb84..a54ce5708 100644 --- a/weed/mq/segment/message_serde_test.go +++ b/weed/mq/segment/message_serde_test.go @@ -17,6 +17,7 @@ func TestMessageSerde(t *testing.T) { bb := NewMessageBatchBuilder(b, 1, 2, 3, 4) bb.AddMessage(5, 6, prop, []byte("the primary key"), []byte("body is here")) + bb.AddMessage(5, 7, prop, []byte("the primary 2"), []byte("body is 2")) bb.BuildMessageBatch() @@ -33,9 +34,9 @@ func TestMessageSerde(t *testing.T) { assert.Equal(t, int64(5), mb.SegmentSeqBase()) assert.Equal(t, int32(0), mb.SegmentSeqMaxDelta()) assert.Equal(t, int64(6), mb.TsMsBase()) - assert.Equal(t, int32(0), mb.TsMsMaxDelta()) + assert.Equal(t, int32(1), mb.TsMsMaxDelta()) - assert.Equal(t, 1, mb.MessagesLength()) + assert.Equal(t, 2, mb.MessagesLength()) m := &message_fbs.Message{} mb.Messages(m, 0) |