I ran into a scenario where I have multiple Scheduled Messages with a cron
string set to fire every minute that are created at different times.
However, only one is firing every minute (cycles 0 to 9). Is this as
intended?
Here is some sample code to that generates the same behavior:
String url = "tcp://localhost:61616";
ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(null, null, url);
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
connection.start();
String cronEveryMinute = "* * * * *";
for (int i = 0; i < 10; i++) {
String queueName = "scheduled.test"+i;
Queue destination = session.createQueue(queueName);
MessageProducer producer = session.createProducer(destination);
String msg = "Sample message for queue "+queueName;
TextMessage message = session.createTextMessage(msg);
message.setStringProperty(ScheduledMessage.AMQ_SCHEDULED_CRON,
cronEveryMinute);
producer.send(message);
producer.close();
//wait a couple sec so cron start time is different for next job
Thread.sleep(2000);
}
connection.close();
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Multiple-Scheduled-Messages-Not-Firing-tp3004226p3004226.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.