Reverted "message.setJMSPriority(priority);"

datastax · Aug 20, 2024 · f6f9992 · f6f9992
1 parent 5da998c
commit f6f9992
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-jms/src/main/java/com/datastax/oss/pulsar/jms/PulsarJMSProducer.java b/pulsar-jms/src/main/java/com/datastax/oss/pulsar/jms/PulsarJMSProducer.java
@@ -191,6 +191,7 @@ private void getProducerAndSend(Destination destination, Message message) throws
     for (Map.Entry<String, Object> prop : properties.entrySet()) {
       message.setObjectProperty(prop.getKey(), prop.getValue());
     }
+    message.setJMSPriority(priority);
 
     if (completionListener != null) {
       producer.send(destination, message, deliveryMode, priority, timeToLive, completionListener);