up default # of retries, as circleci now slower than normal!

jameshnsears · Jan 23, 2019 · e16925e · e16925e
1 parent 6c88dcb
commit e16925e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/src/main/java/xqa/IngestBalancer.java b/src/main/java/xqa/IngestBalancer.java
@@ -88,7 +88,7 @@ private void setConfigurationValues(final Options options, final CommandLine com
         messageBrokerPort = Integer.parseInt(commandLine.getOptionValue("message_broker_port", "5672"));
         messageBrokerUsername = commandLine.getOptionValue("message_broker_username", "admin");
         messageBrokerPassword = commandLine.getOptionValue("message_broker_password", "admin");
-        messageBrokerRetryAttempts = Integer.parseInt(commandLine.getOptionValue("message_broker_retry", "3"));
+        messageBrokerRetryAttempts = Integer.parseInt(commandLine.getOptionValue("message_broker_retry", "10"));
 
         destinationIngest = commandLine.getOptionValue("destination_ingest", "xqa.ingest");
         destinationEvent = commandLine.getOptionValue("destination_event", "xqa.event");

diff --git a/src/main/java/xqa/InserterThread.java b/src/main/java/xqa/InserterThread.java
@@ -108,6 +108,8 @@ private synchronized List<Message> getSizeResponses(final MessageBroker shardSiz
 
     private synchronized void placeMessageBackOnOriginatingDestination()
             throws JMSException, MessageBroker.MessageBrokerException {
+        logger.warn("placeMessageBackOnOriginatingDestination");
+
         final Message message =
                 MessageMaker.createMessage(
                         inserterThreadMessageBroker.getSession(),

diff --git a/IngestBalancer.launch → xqa-ingest-balancer.launch b/IngestBalancer.launch → xqa-ingest-balancer.launch