Author: dejanb
Date: Tue Oct 5 13:51:55 2010
New Revision: 1004640
URL: http://svn.apache.org/viewvc?rev=1004640&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQ-2954 - test scheduling after
restart
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java?rev=1004640&r1=1004639&r2=1004640&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
(original)
+++
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java
Tue Oct 5 13:51:55 2010
@@ -205,6 +205,12 @@ public class JmsSchedulerTest extends Em
MessageConsumer consumer = session.createConsumer(destination);
Message msg = consumer.receive(5000);
assertNotNull("Didn't receive the message", msg);
+
+ //send another message
+ producer = session.createProducer(destination);
+ message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time);
+ producer.send(message);
+ producer.close();
}
@Override
