[ISSUE #166] fix concurrency for message property string (#1141)

* should use BrokerName for send back since the StoreHost in msg may not reachable in cloud env * fix message string concurrent map issue
apache · Sep 4, 2024 · 447cf73 · 447cf73
1 parent fe4b42e
commit 447cf73
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/primitive/message.go b/primitive/message.go
@@ -211,7 +211,7 @@ func (m *Message) GetShardingKey() string {
 
 func (m *Message) String() string {
 	return fmt.Sprintf("[topic=%s, body=%s, Flag=%d, properties=%v, TransactionId=%s]",
-		m.Topic, string(m.Body), m.Flag, m.properties, m.TransactionId)
+		m.Topic, string(m.Body), m.Flag, m.MarshallProperties(), m.TransactionId)
 }
 
 func (m *Message) Marshal() []byte {