I have tried both 5.4.2 and 5.5 and have been unable to get the scheduler to
work.  I have set
schedulerSupport=true in the activemq-specjms.xml file.

My code looks as follows:

public void scheduleMessage() throws JMSException {
        Destination destination = new 
ActiveMQQueue("OutboxTwitterUpdateStatus");               
        String json = TwitterPojoFactory.make().asJson();

        session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
        MessageProducer producer = session.createProducer(destination);
        TextMessage message = session.createTextMessage(json);
        
        // Cron: # m h dom mon dow
        message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_ID, "0");
        message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY,
"60000");
       
System.out.println(message.getStringProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY));
        producer.send(message);
}

--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Scheduler-Broken-tp3545460p3545460.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Reply via email to