diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java index a7aac198a0..62a9ad36c1 100644 --- a/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/broker/scheduler/JmsSchedulerTest.java @@ -205,6 +205,12 @@ public class JmsSchedulerTest extends EmbeddedBrokerTestSupport { 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