Merge pull request #166 from reportportal/develop

Release
reportportal · Aug 5, 2021 · 5f685b0 · 5f685b0
2 parents d135931 + 3ef8189
commit 5f685b0
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/src/main/java/com/epam/reportportal/service/statistics/StatisticsClient.java b/src/main/java/com/epam/reportportal/service/statistics/StatisticsClient.java
@@ -175,15 +175,6 @@ private Map<String, String> buildPostRequest(StatisticsItem item) {
 
 	@Override
 	public void close() {
-		ofNullable(executor).ifPresent(e -> {
-			e.shutdown();
-			try {
-				if (!e.awaitTermination(10, TimeUnit.SECONDS)) {
-					e.shutdownNow();
-				}
-			} catch (InterruptedException ignore) {
-			}
-		});
 		ofNullable(httpClient).ifPresent(c -> {
 			ExecutorService e = c.dispatcher().executorService();
 			e.shutdown();
@@ -195,5 +186,8 @@ public void close() {
 			}
 			c.connectionPool().evictAll();
 		});
+		httpClient = null;
+		ofNullable(executor).ifPresent(ExecutorService::shutdownNow);
+		executor = null;
 	}
 }
diff --git a/src/main/java/com/epam/reportportal/service/statistics/StatisticsService.java b/src/main/java/com/epam/reportportal/service/statistics/StatisticsService.java
@@ -104,7 +104,11 @@ public void sendEvent(Maybe<String> launchIdMaybe, StartLaunchRQ rq) {
 		//noinspection ResultOfMethodCallIgnored
 		statisticsMaybe.subscribe(t -> {
 			ofNullable(t.body()).ifPresent(ResponseBody::close);
-		}, t -> LOGGER.error("Unable to send statistics", t));
+			getStatistics().close();
+		}, t -> {
+			LOGGER.error("Unable to send statistics", t);
+			getStatistics().close();
+		});
 	}
 
 	@Override