diff --git a/src/main/kotlin/civilengineering/bridge/MessageHandler.kt b/src/main/kotlin/civilengineering/bridge/MessageHandler.kt index e223539..018abf8 100644 --- a/src/main/kotlin/civilengineering/bridge/MessageHandler.kt +++ b/src/main/kotlin/civilengineering/bridge/MessageHandler.kt @@ -42,7 +42,7 @@ object MessageHandler { var rcvQueue = ConcurrentLinkedQueue() fun transmit(msg: ApiMessage) { - if (connected) { + if (connected && streamConnection.isAlive) { CivilEngineering.logger.debug("Transmitting: " + msg) transmitMessage(msg) }