From 6b4245192361c047411005a4574621687efd728c Mon Sep 17 00:00:00 2001 From: Paul Lorenz Date: Thu, 17 Mar 2022 13:33:35 -0400 Subject: [PATCH] Fix flaky test --- tests/testutil/message_collector.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tests/testutil/message_collector.go b/tests/testutil/message_collector.go index f8812c8d0..4ecde4244 100644 --- a/tests/testutil/message_collector.go +++ b/tests/testutil/message_collector.go @@ -25,6 +25,10 @@ type MessageCollector struct { } func (self *MessageCollector) HandleReceive(m *channel.Message, ch channel.Channel) { + if m.ContentType == -33 { + logrus.Debug("ignoring reconnect ping") + return + } select { case self.msgs <- m: decoded := fmt.Sprintf("ContentType: %v", m.ContentType)