Updated timeout for commandline imports to 5 minutes from 30s

Author: chilimannen

src/main/java/com/codingchili/ApplicationLauncher.java

@@ -14,9 +14,11 @@
 import com.codingchili.Model.ParserException;
 
 import io.vertx.core.*;
+import io.vertx.core.eventbus.DeliveryOptions;
 import io.vertx.core.eventbus.MessageConsumer;
 
 import static com.codingchili.Model.ElasticWriter.ES_STATUS;
+import static com.codingchili.Model.ElasticWriter.INDEXING_TIMEOUT;
 
 /**
  * @author Robin Duda
@@ -91,7 +93,10 @@ private void importFile(String fileName, String indexName) {
                 try {
                     FileParser parser = new FileParser(file.result().getBytes(), 1, fileName);
                     logger.info(String.format("File parsed, starting import to %s..", indexName));
-                    vertx.eventBus().send(Configuration.INDEXING_ELASTICSEARCH, parser.toImportable(indexName, getMapping()), done -> {
+                    vertx.eventBus().send(Configuration.INDEXING_ELASTICSEARCH,
+                            parser.toImportable(indexName, getMapping()),
+                            new DeliveryOptions().setSendTimeout(INDEXING_TIMEOUT),
+                            done -> {
                         if (done.succeeded()) {
                             logger.info("Import completed, shutting down.");
                         } else {

src/main/java/com/codingchili/Controller/Website.java

@@ -21,6 +21,7 @@
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
+import static com.codingchili.Model.ElasticWriter.INDEXING_TIMEOUT;
 import static com.codingchili.Model.FileParser.INDEX;
 
 /**
@@ -30,7 +31,6 @@
  */
 public class Website extends AbstractVerticle {
     public static final String MAPPING = "mapping";
-    private static final int INDEXING_TIMEOUT = 300000;
     private Logger logger = Logger.getLogger(getClass().getName());
     private static final String DONE = "/done";
     private static final String ERROR = "/error";

src/main/java/com/codingchili/Model/ElasticWriter.java

@@ -16,6 +16,7 @@
  *         Writes json data to elasticsearch for indexing.
  */
 public class ElasticWriter extends AbstractVerticle {
+    public static final int INDEXING_TIMEOUT = 300000;
     private static final String INDEX = "index";
     private static final String BULK = "/_bulk";
     private static final int POLL = 5000;