diff --git a/session.go b/session.go index ab53935e5..b359245e2 100644 --- a/session.go +++ b/session.go @@ -367,6 +367,11 @@ func (s *session) EnqueueBytesAndSend(msg []byte) { } func (s *session) sendBytes(msg []byte) { + if s.messageOut == nil { + s.log.OnEventf("Failed to send: disconnected") + return + } + s.log.OnOutgoing(msg) s.messageOut <- msg s.stateTimer.Reset(s.HeartBtInt)