@Override
                public void receiveMessages(PeerInfo peerInfo, List<Message> messages) throws InterruptedException {
                    for (Message message : messages) {
                        System.out.println(new String(message.getData()));
                        msgCount.getAndIncrement();
                    }
                }
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