Merge pull request openziti/fabric#334 from openziti/fix-flaky-test

Fix flaky test
This commit is contained in:
Paul Lorenz
2022-03-17 13:45:51 -04:00
committed by GitHub
+4
View File
@@ -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)