发送:
Message msg = new Message( //

                // 在控制台创建的 Topic，即该消息所属的 Topic 名称
                "RocketMQ_test_by_bsy",
                // Message Tag,
                // 可理解为 Gmail 中的标签，对消息进行再归类，方便 Consumer 指定过滤条件在 MQ 服务器过滤
                "TagA",
                // Message Body
                // 任何二进制形式的数据， MQ 不做任何干预，
                // 需要 Producer 与 Consumer 协商好一致的序列化和反序列化方式
                "Hello MQ".getBytes());

接受:
Consumer consumer = ONSFactory.createConsumer(properties);

    consumer.subscribe("RocketMQ_test_by_bsy", "*", new MessageListener() {
        public Action consume(Message message, ConsumeContext context) {
            System.out.println("Receive: " + message);
            return Action.CommitMessage;
        }
    });