From c511ed380e43923e35afd7799da8d9ec1cfd21aa Mon Sep 17 00:00:00 2001
From: Benjamin Gamard <b.gamard@sismics.com>
Date: Sat, 3 Mar 2018 14:39:12 +0100
Subject: [PATCH] inbox service logs

---
 .../sismics/docs/core/model/context/AppContext.java    |  2 ++
 .../com/sismics/docs/core/service/InboxService.java    | 10 +++++++---
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/docs-core/src/main/java/com/sismics/docs/core/model/context/AppContext.java b/docs-core/src/main/java/com/sismics/docs/core/model/context/AppContext.java
index 11df7dc4..5c92f0c1 100644
--- a/docs-core/src/main/java/com/sismics/docs/core/model/context/AppContext.java
+++ b/docs-core/src/main/java/com/sismics/docs/core/model/context/AppContext.java
@@ -74,10 +74,12 @@ public class AppContext {
         Config luceneStorageConfig = configDao.getById(ConfigType.LUCENE_DIRECTORY_STORAGE);
         indexingService = new IndexingService(luceneStorageConfig != null ? luceneStorageConfig.getValue() : null);
         indexingService.startAsync();
+        indexingService.awaitRunning();
 
         // Start inbox service
         inboxService = new InboxService();
         inboxService.startAsync();
+        indexingService.awaitRunning();
 
         // Register fonts
         PdfUtil.registerFonts();
diff --git a/docs-core/src/main/java/com/sismics/docs/core/service/InboxService.java b/docs-core/src/main/java/com/sismics/docs/core/service/InboxService.java
index 4106e135..4985c1cb 100644
--- a/docs-core/src/main/java/com/sismics/docs/core/service/InboxService.java
+++ b/docs-core/src/main/java/com/sismics/docs/core/service/InboxService.java
@@ -54,7 +54,11 @@ public class InboxService extends AbstractScheduledService {
     
     @Override
     protected void runOneIteration() {
-        syncInbox();
+        try {
+            syncInbox();
+        } catch (Exception e) {
+            log.error("Exception during inbox synching", e);
+        }
     }
 
     /**
@@ -77,7 +81,7 @@ public class InboxService extends AbstractScheduledService {
                 try {
                     inbox = openInbox();
                     Message[] messages = inbox.search(new FlagTerm(new Flags(Flags.Flag.SEEN), false));
-                    log.info(messages.length + " messages found, importing...");
+                    log.info(messages.length + " messages found");
                     for (Message message : messages) {
                         importMessage(message);
                         lastSyncMessageCount++;
@@ -131,7 +135,7 @@ public class InboxService extends AbstractScheduledService {
 
     @Override
     protected Scheduler scheduler() {
-        return Scheduler.newFixedDelaySchedule(0, 15, TimeUnit.MINUTES);
+        return Scheduler.newFixedDelaySchedule(0, 1, TimeUnit.MINUTES);
     }
 
     /**