From e476a2121c5d0eea56bcd514672ff873ebaafbb5 Mon Sep 17 00:00:00 2001
From: Simon Brandhof <simon.brandhof@sonarsource.com>
Date: Wed, 4 Mar 2015 10:41:15 +0100
Subject: [PATCH] Async replication of activity docs

---
 .../java/org/sonar/server/activity/index/ActivityIndexer.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/server/sonar-server/src/main/java/org/sonar/server/activity/index/ActivityIndexer.java b/server/sonar-server/src/main/java/org/sonar/server/activity/index/ActivityIndexer.java
index 1a668bd5a8f..2b4ba6e678e 100644
--- a/server/sonar-server/src/main/java/org/sonar/server/activity/index/ActivityIndexer.java
+++ b/server/sonar-server/src/main/java/org/sonar/server/activity/index/ActivityIndexer.java
@@ -19,6 +19,7 @@
  */
 package org.sonar.server.activity.index;
 
+import org.elasticsearch.action.support.replication.ReplicationType;
 import org.elasticsearch.action.update.UpdateRequest;
 import org.sonar.core.persistence.DbSession;
 import org.sonar.server.db.DbClient;
@@ -84,6 +85,7 @@ public class ActivityIndexer extends BaseIndexer {
   private UpdateRequest newUpsertRequest(ActivityDoc doc) {
     return new UpdateRequest(ActivityIndexDefinition.INDEX, ActivityIndexDefinition.TYPE, doc.getKey())
       .doc(doc.getFields())
-      .upsert(doc.getFields());
+      .upsert(doc.getFields())
+      .replicationType(ReplicationType.ASYNC);
   }
 }
-- 
2.39.5