diff options
Diffstat (limited to 'java/client/example/src')
2 files changed, 3 insertions, 2 deletions
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java index b5f8dfda9b..259756764c 100644 --- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java @@ -24,6 +24,7 @@ import java.util.Properties; import javax.jms.Connection; import javax.jms.ConnectionFactory; +import javax.jms.DeliveryMode; import javax.jms.Destination; import javax.jms.ExceptionListener; import javax.jms.JMSException; @@ -43,7 +44,7 @@ public class Producer private static final String CLASS = "Producer"; private int numMessages = 10; - private short deliveryMode = 0; + private short deliveryMode = DeliveryMode.NON_PERSISTENT; /** * Create a Producer client. diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/fanout/Producer.java b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/fanout/Producer.java index 6438e74ac7..2e360f37bb 100755 --- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/fanout/Producer.java +++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/fanout/Producer.java @@ -36,7 +36,7 @@ public class Producer /* The queue name */ private int numMessages = 10; - private short deliveryMode = 0; + private short deliveryMode = DeliveryMode.NON_PERSISTENT; /** |
