File tree Expand file tree Collapse file tree 1 file changed +7
-5
lines changed
analytics/src/main/java/com/segment/analytics/internal Expand file tree Collapse file tree 1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -234,9 +234,9 @@ public void shutdown() {
234234 }
235235
236236 /**
237- * Wait for the looper to complete processing all messages before proceeding with shutdown.
238- * This prevents the race condition where the network executor is shut down before the looper
239- * finishes submitting all batches.
237+ * Wait for the looper to complete processing all messages before proceeding with shutdown. This
238+ * prevents the race condition where the network executor is shut down before the looper finishes
239+ * submitting all batches.
240240 */
241241 private void waitForLooperCompletion () {
242242 if (looperFuture != null ) {
@@ -333,8 +333,10 @@ public void run() {
333333 networkExecutor .submit (
334334 BatchUploadTask .create (AnalyticsClient .this , batch , maximumRetries ));
335335 } catch (RejectedExecutionException e ) {
336- log .print (ERROR , e ,
337- "Failed to submit batch %s to network executor during shutdown. Batch will be lost." ,
336+ log .print (
337+ ERROR ,
338+ e ,
339+ "Failed to submit batch %s to network executor during shutdown. Batch will be lost." ,
338340 batch .sequence ());
339341 // Notify callbacks about the failure
340342 for (Message msg : batch .batch ()) {
You can’t perform that action at this time.
0 commit comments