diff options
Diffstat (limited to 'weed/mq/segment')
| -rw-r--r-- | weed/mq/segment/message_serde.go | 4 | ||||
| -rw-r--r-- | weed/mq/segment/message_serde_test.go | 6 |
2 files changed, 5 insertions, 5 deletions
diff --git a/weed/mq/segment/message_serde.go b/weed/mq/segment/message_serde.go index 66a76c57d..ee55b18a7 100644 --- a/weed/mq/segment/message_serde.go +++ b/weed/mq/segment/message_serde.go @@ -35,7 +35,7 @@ func NewMessageBatchBuilder(b *flatbuffers.Builder, } } -func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, properties map[string][]byte, key []byte, value []byte) { +func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, properties map[string]string, key []byte, value []byte) { if builder.segmentSeqBase == 0 { builder.segmentSeqBase = segmentSeq } @@ -48,7 +48,7 @@ func (builder *MessageBatchBuilder) AddMessage(segmentSeq int64, tsMs int64, pro var names, values, pairs []flatbuffers.UOffsetT for k, v := range properties { names = append(names, builder.b.CreateString(k)) - values = append(values, builder.b.CreateByteVector(v)) + values = append(values, builder.b.CreateString(v)) } for i, _ := range names { message_fbs.NameValueStart(builder.b) diff --git a/weed/mq/segment/message_serde_test.go b/weed/mq/segment/message_serde_test.go index c65bffb84..30c3d784a 100644 --- a/weed/mq/segment/message_serde_test.go +++ b/weed/mq/segment/message_serde_test.go @@ -10,9 +10,9 @@ import ( func TestMessageSerde(t *testing.T) { b := flatbuffers.NewBuilder(1024) - prop := make(map[string][]byte) - prop["n1"] = []byte("v1") - prop["n2"] = []byte("v2") + prop := make(map[string]string) + prop["n1"] = "v1" + prop["n2"] = "v2" bb := NewMessageBatchBuilder(b, 1, 2, 3, 4) |