DefaultMQProducer producer = new DefaultMQProducer("group_name"); producer.setNamesrvAddr("name_server_address"); producer.start(); Message message = new Message("topic_name", "tag_name", "message_body".getBytes()); SendResult sendResult = producer.send(message); System.out.println(sendResult); producer.shutdown(); DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group_name"); consumer.setNamesrvAddr("name_server_address"); consumer.subscribe("topic_name", "tag_name"); consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> { System.out.println("Received Messages: " + msgs); return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }); consumer.start();