summaryrefslogtreecommitdiff
path: root/java/client/example
diff options
context:
space:
mode:
Diffstat (limited to 'java/client/example')
-rw-r--r--java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java7
1 files changed, 2 insertions, 5 deletions
diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java
index 4eac17f380..1cc46a8cef 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java
@@ -25,9 +25,7 @@ import javax.naming.Context;
import javax.naming.InitialContext;
import java.util.Properties;
-/**
- * Message producer example, sends message to a queue.
- */
+
public class Hello {
private static final String CLASS = "Hello";
@@ -42,7 +40,6 @@ public class Hello {
private void runTest() {
try {
- // Create JNDI context
Properties properties = new Properties();
properties.load(this.getClass().getResourceAsStream("hello.properties"));
Context context = new InitialContext(properties);
@@ -55,7 +52,7 @@ public class Hello {
}
});
- Session session = connection.createSession();
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = (Destination) context.lookup("topicExchange");
MessageProducer messageProducer = session.createProducer(destination);