public void shutdown() {
            logger.info("[SHUTDOWN_TUBE] Shutting down connectionManager.");
            isRunning = false;
        }
ConnectionManager
Manage and recycle network connection resources
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/RpcServiceFactory.java