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 index a1eacae6..481524ea 100644 --- 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 prop : properties.entrySet()) { message.setObjectProperty(prop.getKey(), prop.getValue()); } + message.setJMSPriority(priority); if (completionListener != null) { producer.send(destination, message, deliveryMode, priority, timeToLive, completionListener);