private void syncProduce(Message message) throws TubeClientException, InterruptedException {
            MessageSentResult result = messageProducer.sendMessage(message);
            if (!result.isSuccess()) {
                System.out.println("sync send message failed : " + result.getErrMsg());
            } else {
                msgCount.getAndIncrement();
            }
        }
Send messages in synchronous mode

@param message  Message to send
@throws TubeClientException
@throws InterruptedException
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/MessageCommand.java