close channel when write fails before read

Signed-off-by: dorjesinpo <[email protected]>

Author: dorjesinpo

src/groups/bmq/bmqimp/bmqimp_application.cpp

@@ -288,6 +288,9 @@ void Application::channelStateCallback(
         BALL_LOG_ERROR << id() << "Could not establish session with '"
                        << endpoint << "' [event: " << event
                        << ", status: " << status << "]";
+        if (channel) {
+            channel->close(status);
+        }
     } break;  // BREAK
     default: {
         BALL_LOG_ERROR << id() << "Session with '" << endpoint << "' is now"