Update pulsar-jms/src/main/java/com/datastax/oss/pulsar/jms/PulsarJMS…

…Producer.java Co-authored-by: Andrey Yegorov <[email protected]>
datastax · Aug 14, 2024 · 171545a · 171545a
1 parent 936133c
commit 171545a
Showing 1 changed file with 6 additions and 6 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
@@ -194,14 +194,14 @@ private void getProducerAndSend(Destination destination, Message message) throws
     if (message.getJMSPriority() != Message.DEFAULT_PRIORITY) {
       message.setJMSPriority(priority);
     }
-    if (message.getJMSCorrelationIDAsBytes() != null) {
-      message.setJMSCorrelationIDAsBytes(message.getJMSCorrelationIDAsBytes());
+    if (message.getJMSCorrelationIDAsBytes() == null || correlationID != null) {
+      message.setJMSCorrelationIDAsBytes(correlationID);
     }
-    if (message.getJMSType() != null) {
-      message.setJMSType(message.getJMSType());
+    if (message.getJMSType() == null || jmsType != null) {
+      message.setJMSType(jmsType);
     }
-    if (message.getJMSReplyTo() != null) {
-      message.setJMSReplyTo(message.getJMSReplyTo());
+    if (message.getJMSReplyTo() == null || jmsReplyTo != null) {
+      message.setJMSReplyTo(jmsReplyTo);
     }
 
     if (completionListener != null) {