DefaultMQProducer producer = new DefaultMQProducer("ProducerGroup"); producer.start(); Message msg = new Message("TopicName", "TagName", "Hello RocketMQ".getBytes()); producer.send(msg); DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup"); consumer.subscribe("TopicName", "TagName"); consumer.setMessageListener(new MessageListenerConcurrently() { @Override public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) { for (MessageExt msg : msgs) { } return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; } }); consumer.start();