Merge pull request #1027 from middagj/jms-context

Use JMSContext for session mode
quarkusio · Dec 24, 2021 · 95ebc9e · 95ebc9e
2 parents 75edd97 + ff3e5eb
commit 95ebc9e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/jms-quickstart/src/main/java/org/acme/jms/PriceConsumer.java b/jms-quickstart/src/main/java/org/acme/jms/PriceConsumer.java
@@ -11,7 +11,6 @@
 import javax.jms.JMSContext;
 import javax.jms.JMSException;
 import javax.jms.Message;
-import javax.jms.Session;
 
 import io.quarkus.runtime.ShutdownEvent;
 import io.quarkus.runtime.StartupEvent;
@@ -43,7 +42,7 @@ void onStop(@Observes ShutdownEvent ev) {
 
     @Override
     public void run() {
-        try (JMSContext context = connectionFactory.createContext(Session.AUTO_ACKNOWLEDGE)) {
+        try (JMSContext context = connectionFactory.createContext(JMSContext.AUTO_ACKNOWLEDGE)) {
             JMSConsumer consumer = context.createConsumer(context.createQueue("prices"));
             while (true) {
                 Message message = consumer.receive();

diff --git a/jms-quickstart/src/main/java/org/acme/jms/PriceProducer.java b/jms-quickstart/src/main/java/org/acme/jms/PriceProducer.java
@@ -10,7 +10,6 @@
 import javax.inject.Inject;
 import javax.jms.ConnectionFactory;
 import javax.jms.JMSContext;
-import javax.jms.Session;
 
 import io.quarkus.runtime.ShutdownEvent;
 import io.quarkus.runtime.StartupEvent;
@@ -37,7 +36,7 @@ void onStop(@Observes ShutdownEvent ev) {
 
     @Override
     public void run() {
-        try (JMSContext context = connectionFactory.createContext(Session.AUTO_ACKNOWLEDGE)) {
+        try (JMSContext context = connectionFactory.createContext(JMSContext.AUTO_ACKNOWLEDGE)) {
             context.createProducer().send(context.createQueue("prices"), Integer.toString(random.nextInt(100)));
         }
     }