Strip message tags in error message
The time tag was causing the registration error messages to be continuously sent to downstream connections.
This commit is contained in:
parent
78361f0b1e
commit
ee32329a14
@ -1520,6 +1520,7 @@ func (uc *upstreamConn) runUntilRegistered() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if err := uc.handleMessage(msg); err != nil {
|
if err := uc.handleMessage(msg); err != nil {
|
||||||
|
msg.Tags = nil // prevent message tags from cluttering logs
|
||||||
return fmt.Errorf("failed to handle message %q: %v", msg, err)
|
return fmt.Errorf("failed to handle message %q: %v", msg, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user