fix: always run middleware flush on updateServer (#400)

amplitude · Apr 17, 2024 · fbee357 · fbee357
1 parent 79aab5f
commit fbee357
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/amplitude/api/AmplitudeClient.java b/src/main/java/com/amplitude/api/AmplitudeClient.java
@@ -2122,7 +2122,6 @@ public void run() {
                 }
                 identifyInterceptor.transferInterceptedIdentify();
                 updateServer();
-                middlewareRunner.flush();
             }
         });
     }
@@ -2159,6 +2158,9 @@ protected void updateServer(boolean limit) {
             return;
         }
 
+        // Flush middleware
+        middlewareRunner.flush();
+
         // if returning out of this block, always be sure to set uploadingCurrently to false!!
         if (!uploadingCurrently.getAndSet(true)) {
             long totalEventCount = dbHelper.getTotalEventCount();