| commit | 4550dac6c87b8d721d1c5a22e92848a4af30e4d4 | [log] [tgz] |
|---|---|---|
| author | Timothy Bish <tabish121@gmail.com> | Tue Sep 20 14:23:53 2016 -0400 |
| committer | Timothy Bish <tabish121@gmail.com> | Tue Sep 20 14:23:53 2016 -0400 |
| tree | 1e702b1a18d7ea7dad1e66e519e94f18c6a5f150 | |
| parent | fd2bc18322b388dd38bb53a526a01ce3d7fcf149 [diff] |
QPIDJMS-207 Fix MessageProducer getDeliveryDelay, add test
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java index 6e9c96d..64cdf8b 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsMessageProducer.java
@@ -114,7 +114,7 @@ @Override public long getDeliveryDelay() throws JMSException { checkClosed(); - return deliveryMode; + return deliveryDelay; } @Override
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/producer/JmsMessageProducerTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/producer/JmsMessageProducerTest.java index a2629a9..319ce3f 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/producer/JmsMessageProducerTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/producer/JmsMessageProducerTest.java
@@ -133,6 +133,14 @@ } @Test(timeout = 10000) + public void testDeliveryDelayConfiguration() throws Exception { + MessageProducer producer = session.createProducer(null); + assertEquals(Message.DEFAULT_DELIVERY_DELAY, producer.getDeliveryDelay()); + producer.setDeliveryDelay(2000); + assertEquals(2000, producer.getDeliveryDelay()); + } + + @Test(timeout = 10000) public void testAnonymousProducerThrowsUOEWhenExplictDestinationNotProvided() throws Exception { JmsMessageProducer producer = (JmsMessageProducer) session.createProducer(null);