public void shutdown() throws Throwable {
        // stop process
        if (sendExecutorService != null) {
            sendExecutorService.shutdownNow();
        }
        ThreadUtils.sleep(20);
        for (MessageProducer producer : producerMap.keySet()) {
            producer.shutdown();
        }
        for (MessageSessionFactory messageSessionFactory : sessionFactoryList) {
            messageSessionFactory.shutdown();
        }
    }
Initializes the TubeMQ producer client(s) with the specified requirements.
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliProducer.java