pba: Fix correlation ID prefix

barryzxy · Oct 11, 2023 · bacbbcc · bacbbcc
1 parent c8517d0
commit bacbbcc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/packetbrokeragent/agent.go b/pkg/packetbrokeragent/agent.go
@@ -960,7 +960,7 @@ func (a *Agent) handleUplink(
 		if up.Message == nil {
 			return
 		}
-		ctx = appendDownlinkCorrelationID(ctx, up.Id)
+		ctx = appendUplinkCorrelationID(ctx, up.Id)
 		var forwarderNetID types.NetID
 		forwarderNetID.UnmarshalNumber(up.ForwarderNetId)
 		ctx = log.NewContextWithFields(ctx, log.Fields(