diff --git a/messaging/client.go b/messaging/client.go index 11a9eba28e..260c956e78 100644 --- a/messaging/client.go +++ b/messaging/client.go @@ -674,9 +674,9 @@ func (c *Conn) stream(req *http.Request, closing <-chan struct{}) error { return fmt.Errorf("decode: %s", err) } - // Panic if we received no data. + // Log if we received a message with no data. if len(m.Data) == 0 { - panic("messaging conn no data recv") + c.Logger.Printf("conn recv message w/ no data: type=%x", m.Type) } // TODO: Write broker set updates, do not passthrough to channel.