quickstart.md

回目录 下一页

快速入门

以下示例只是表明及其简洁的API，具体详细的用法请参照后面具体文档

发送消息

MessageProducerProvider producer = new MessageProducerProvider();
producer.init();

Message message = producer.generateMessage("your subject");
message.setProperty("key", "value");
//发送延迟消息
//message.setDelayTime(15, TimeUnit.MINUTES);
producer.sendMessage(message);

消费消息

@QmqConsumer(subject = "your subject", consumerGroup = "group", executor = "your executor")
public void onMessage(Message message){
    //process your message
    String value = message.getStringProperty("key");
}

回目录 下一页