summaryrefslogtreecommitdiff
path: root/java/client/example/src
diff options
context:
space:
mode:
Diffstat (limited to 'java/client/example/src')
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/jmsexample/direct/Producer.java3
-rwxr-xr-xjava/client/example/src/main/java/org/apache/qpid/example/jmsexample/fanout/Producer.java2
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;
/**