diff --git a/pkg/node/transport.go b/pkg/node/transport.go index 7c69d33..412edf8 100644 --- a/pkg/node/transport.go +++ b/pkg/node/transport.go @@ -64,11 +64,11 @@ type MessageDeduplicator struct { // dedup.Mark(msg.ID) // if dedup.IsDuplicate(msg.ID) { continue } func NewMessageDeduplicator(ttl time.Duration) *MessageDeduplicator { - d := &MessageDeduplicator{ + deduplicator := &MessageDeduplicator{ seen: make(map[string]time.Time), ttl: ttl, } - return d + return deduplicator } // if dedup.IsDuplicate(msg.ID) { continue } // drop already-processed message