Changeset 440 in code for trunk/downstream.go

Timestamp:

Jan 4, 2021, 3:26:30 PM (4 years ago)

Author:

contact

Message:

Add store-agnostic message ID format

Allow to query the network ID and entity from the message ID regardless
of the underlying store used.

File:

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

trunk/downstream.go

@@ -314 +314 @@
 // ackMsgID acknowledges that a message has been received.
 func (dc *downstreamConn) ackMsgID(id string) {
-        netName, entity, _, _, err := parseMsgID(id)
+        netID, entity, _, err := parseMsgID(id)
         if err != nil {
                 dc.logger.Printf("failed to ACK message ID %q: %v", id, err)
@@ -320 +320 @@
         }
 
-        network := dc.user.getNetwork(netName)
+        network := dc.user.getNetworkByID(netID)
         if network == nil {
                 return