@Override
                public Executor getExecutor() {
                    return null;
                }
Create a pushConsumer and consume messages

@param messageSessionFactory
@param consumerConfig
@throws TubeClientException
@throws InterruptedException
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/MessageCommand.java