circleci

jameshnsears · Dec 23, 2018 · fec0d21 · fec0d21
1 parent 43e817d
commit fec0d21
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/main/java/xqa/InserterThread.java b/src/main/java/xqa/InserterThread.java
@@ -109,13 +109,19 @@ private synchronized List<Message> getSizeResponses(MessageBroker shardSizeMessa
 
     private synchronized void placeMessageBackOnOriginatingDestination()
             throws JMSException, UnsupportedEncodingException, MessageBroker.MessageBrokerException {
-        inserterThreadMessageBroker.sendMessage(
+        Message message =
                 MessageMaker.createMessage(
                         inserterThreadMessageBroker.getSession(),
                         inserterThreadMessageBroker.getSession().createQueue("xqa.ingest"),
-                        ingestMessage.getJMSType(),
                         ingestMessage.getJMSCorrelationID(),
-                MessageMaker.getBody(ingestMessage)));
+                        ingestMessage.getJMSType(),
+                        MessageMaker.getBody(ingestMessage));
+
+        logger.warn(message.getJMSCorrelationID());
+        logger.warn(message.getJMSType());
+        logger.warn(DigestUtils.sha256Hex(MessageMaker.getBody(message)));
+
+        inserterThreadMessageBroker.sendMessage(message);
     }
 
     public Message findSmallestShard(List<Message> shardSizeResponses) throws Exception {