Activemq-- delayed delivery and scheduled delivery

Delayed and timed message delivery

stay activemq.xml Active in file schedulerSupport Properties of ：

Property name	type	description
AMQ_SCHEDULED_DELAY	long	Delay message delivery time
AMQ_SCHEDULED_PERIOD	long	The time interval between repeated deliveries
AMQ_SCHEDULED_REPEAT	int	Number of repeated deliveries
AMQ_SCHEDULED_CRON	String	Use cron expression

To configure schedulerSupport=true attribute ：

Code

producer

public class JmsProducerDelayAndSheduler {
    
    public static final String ACTIVEMQ_URL = "tcp://localhost:61616";

    public static final String USERNAME = "admin";

    public static final String PASSWORD = "hll123";

    public static final String QUEUE_NAME = "queue01";

    public static void main(String[] args) throws Exception {
    
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, ACTIVEMQ_URL);

        Connection connection = activeMQConnectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        Queue queue = session.createQueue(QUEUE_NAME);

        MessageProducer messageProducer = session.createProducer(queue);

        int delay = 5000; // Delay delivery time 
        int period = 3000; // Repeat delivery interval 
        int repeat = 3; // Number of repeated deliveries 

        for (int i = 1; i < 3; i++) {
    
            TextMessage textMessage = session.createTextMessage("delay msg:" + UUID.randomUUID().toString());

            //  Set through the message properties learned above   Delayed delivery and scheduled delivery 
            //  Be careful  message The set attribute type should correspond to ,Long, Int
            textMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay);
            textMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_PERIOD, period);
            //  Use of delivery times setIntProperty
            textMessage.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_REPEAT, repeat);

            messageProducer.send(textMessage);
        }

        messageProducer.close();
        session.close();
        connection.close();

        System.out.println(" ****  Message sent to MQ complete  **** ");
    }
}

---

consumer

public class JmsConsumerDelayAndScheduler {
    

    //  The code is the same as the normal consumer code 

    public static final String ACTIVEMQ_URL = "tcp://localhost:61616";

    public static final String USERNAME = "admin";

    public static final String PASSWORD = "hll123";

    public static final String QUEUE_NAME = "queue01";

    public static void main(String[] args) throws Exception {
    
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, ACTIVEMQ_URL);
        Connection connection = activeMQConnectionFactory.createConnection();
        connection.start();
        Session session = connection.createSession(false,  Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue(QUEUE_NAME);
        MessageConsumer messageConsumer = session.createConsumer(queue);
        messageConsumer.setMessageListener(new MessageListener() {
    
            @Override
            public void onMessage(Message message) {
    
                if (null != message && message instanceof TextMessage) {
    
                    TextMessage textMessage = (TextMessage) message;
                    try {
    
                        System.out.println("****  Consumer receives message  ****：" + textMessage.getText());
                    } catch (JMSException e) {
    
                        e.printStackTrace();
                    }
                }
            }
        });
        System.in.read(); //  You must add a line of code , Otherwise, the program will run directly down and end 
        messageConsumer.close();
        session.close();
        connection.close();
        System.out.println("****  Consumer message complete  ****");
    }
}