Changeset 211 in code for trunk/downstream.go

Timestamp:

Apr 3, 2020, 2:55:49 PM (5 years ago)

Author:

contact

Message:

Add support for downstream echo-message extension

File:

• trunk/downstream.go (modified) (4 diffs)

trunk/downstream.go

@@ -380 +380 @@
                 }
 
-                caps := []string{"message-tags", "server-time"}
+                caps := []string{"message-tags", "server-time", "echo-message"}
 
                 if dc.capVersion >= 302 {
@@ -433 +433 @@
 
                         switch name {
-                        case "sasl", "message-tags", "server-time":
+                        case "sasl", "message-tags", "server-time", "echo-message":
                                 dc.caps[name] = enable
                         default:
@@ -667 +667 @@
         msgTagsEnabled := dc.caps["message-tags"]
         serverTimeEnabled := dc.caps["server-time"]
+        echoMessageEnabled := dc.caps["echo-message"]
 
         consumer, ch := net.ring.NewConsumer(seqPtr)
@@ -693 +694 @@
                                 delete(dc.ourMessages, msg)
                                 dc.lock.Unlock()
-                                if ours {
+                                if ours && !echoMessageEnabled {
                                         // The message comes from our connection, don't echo it
                                         // back