ensure subject also send back to origin ingest queue!

jameshnsears · Dec 21, 2018 · 43e817d · 43e817d
1 parent f66fb70
commit 43e817d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/main/java/xqa/InserterThread.java b/src/main/java/xqa/InserterThread.java
@@ -109,8 +109,12 @@ private synchronized List<Message> getSizeResponses(MessageBroker shardSizeMessa
 
     private synchronized void placeMessageBackOnOriginatingDestination()
             throws JMSException, UnsupportedEncodingException, MessageBroker.MessageBrokerException {
-        inserterThreadMessageBroker.sendMessage(MessageMaker.createMessage(inserterThreadMessageBroker.getSession(),
-                inserterThreadMessageBroker.getSession().createQueue("xqa.ingest"), ingestMessage.getJMSCorrelationID(),
+        inserterThreadMessageBroker.sendMessage(
+                MessageMaker.createMessage(
+                        inserterThreadMessageBroker.getSession(),
+                        inserterThreadMessageBroker.getSession().createQueue("xqa.ingest"),
+                        ingestMessage.getJMSType(),
+                        ingestMessage.getJMSCorrelationID(),
                 MessageMaker.getBody(ingestMessage)));
     }