委托登记消息延迟15s消费
This commit is contained in:
@@ -22,6 +22,7 @@ public class SampleEntrustRegistrationAssayCompleteProducer {
|
|||||||
* @param message
|
* @param message
|
||||||
*/
|
*/
|
||||||
public void sendMessage(SampleEntrustRegistrationAssayCompleteMessage message) {
|
public void sendMessage(SampleEntrustRegistrationAssayCompleteMessage message) {
|
||||||
rocketMQTemplate.syncSend(SampleEntrustRegistrationAssayCompleteMessage.TOPIC, message);
|
// rocketMQTemplate.syncSend(SampleEntrustRegistrationAssayCompleteMessage.TOPIC, message);
|
||||||
|
rocketMQTemplate.syncSendDelayTimeSeconds(SampleEntrustRegistrationAssayCompleteMessage.TOPIC, message, 15);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user