import com.aliyun.openservices.ons.api.*;
import com.aliyun.openservices.shade.org.apache.commons.lang3.time.DateFormatUtils;

import java.util.Date;
import java.util.Properties;

public class ProducerDelayTest {
    public static void main(String[] args) {
        Properties properties = new Properties();
        // AccessKey ID阿里云身份驗(yàn)證，在阿里云RAM控制臺(tái)創(chuàng)建。
        properties.put(PropertyKeyConst.AccessKey, "XXX");
        // AccessKey Secret阿里云身份驗(yàn)證，在阿里云RAM控制臺(tái)創(chuàng)建。
        properties.put(PropertyKeyConst.SecretKey, "XXX");
        // 設(shè)置TCP接入域名，進(jìn)入消息隊(duì)列RocketMQ版控制臺(tái)實(shí)例詳情頁(yè)面的接入點(diǎn)區(qū)域查看。
        properties.put(PropertyKeyConst.NAMESRV_ADDR, "localhost:9876");
        

        Producer producer = ONSFactory.createProducer(properties);
        // 在發(fā)送消息前，必須調(diào)用start方法來(lái)啟動(dòng)Producer，只需調(diào)用一次即可。
        producer.start();

         {
            Message msg = new Message(
                    // 您在消息隊(duì)列RocketMQ版控制臺(tái)創(chuàng)建的Topic。
                    "TopicTest",
                    // Message Tag,可理解為Gmail中的標(biāo)簽，對(duì)消息進(jìn)行再歸類，方便Consumer指定過(guò)濾條件在消息隊(duì)列RocketMQ版服務(wù)器過(guò)濾。
                    "TagA",
                    // Message Body可以是任何二進(jìn)制形式的數(shù)據(jù)，消息隊(duì)列RocketMQ版不做任何干預(yù)，需要Producer與Consumer協(xié)商好一致的序列化和反序列化方式。
                    "演示15秒鐘>>> ".getBytes());
            // 設(shè)置代表消息的業(yè)務(wù)關(guān)鍵屬性，請(qǐng)盡可能全局唯一。
            // 以方便您在無(wú)法正常收到消息情況下，可通過(guò)控制臺(tái)查詢消息并補(bǔ)發(fā)。
            // 注意：不設(shè)置也不會(huì)影響消息正常收發(fā)。
            msg.setKey("ORDERID_100e");
            try {
                // 延時(shí)消息，單位毫秒（ms），在指定延遲時(shí)間（當(dāng)前時(shí)間之后）進(jìn)行投遞，例如消息在15秒后投遞。
                long delayTime = System.currentTimeMillis() + 15000;
                System.out.println("發(fā)送時(shí)間>>" + DateFormatUtils.format(new Date(), "yyyy-MM-dd HH