anchor.diff:  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;
  
positive.code: 
      @Override
      public void run() {
          try (JMSContext context = connectionFactory.createContext(Session.AUTO_ACKNOWLEDGE)) {
              JMSConsumer consumer = context.createConsumer(context.createQueue("prices"));
              while (true) {
                  Message message = consumer.receive();
  
negative.code: 
      @Override
      public void run() {
          try (JMSContext context = connectionFactory.createContext(JMSContext.AUTO_ACKNOWLEDGE)) {
              context.createProducer().send(context.createQueue("prices"), Integer.toString(random.nextInt(100)));
          }
      }
  