Close resources fixed

Update of libraries

Author: jlolling

pom.xml

@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>de.jlo.talendcomp.google</groupId>
 	<artifactId>jlo-talendcomp-google-analytics4</artifactId>
-	<version>1.2</version>
+	<version>1.3</version>
 	<name>GoogleAnalytics Talend Component for GA4</name>
 		<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -25,12 +25,12 @@
 		<dependency>
 			<groupId>com.google.analytics</groupId>
 			<artifactId>google-analytics-data</artifactId>
-			<version>0.24.0</version>
+			<version>0.27.0</version>
 		</dependency>
 		<dependency>
 			<groupId>com.google.auth</groupId>
 			<artifactId>google-auth-library-oauth2-http</artifactId>
-			<version>1.16.0</version>
+			<version>1.16.1</version>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.logging.log4j</groupId>

src/main/java/de/jlo/talendcomp/google/analytics/ga4/GoogleAnalyticsBase.java

@@ -21,6 +21,7 @@
 import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -116,6 +117,22 @@ public void warn(String message) {
 		}
 	}
 
+	public void warn(String message, Throwable t) {
+		if (logger != null) {
+			logger.warn(message, t);
+		} else {
+			System.err.println("WARN:" + message);
+		}
+	}
+
+	public void error(String message) {
+		if (logger != null) {
+			logger.error(message);
+		} else {
+			System.err.println("ERROR:" + message);
+		}
+	}
+
 	public void error(String message, Exception e) {
 		if (logger != null) {
 			if (e != null) {
@@ -132,4 +149,21 @@ public int getTimeoutInSeconds() {
 		return timeoutInSeconds;
 	}
 
+	public void close() {
+		if (analyticsDataClient != null) {
+			info("Close analytics client...");
+			try {
+				analyticsDataClient.shutdown();
+				while (true) {
+					if (analyticsDataClient.awaitTermination(10000, TimeUnit.MILLISECONDS)) {
+						break;
+					}
+				}
+			} catch (Throwable t) {
+				warn("Shutdown analytics client interrupted or failed: " + t.getMessage(), t);
+			}
+		}
+		info("Shutdown analytics client finished");
+	}
+
 }

src/main/java/de/jlo/talendcomp/google/analytics/ga4/v1/GoogleAnalyticsInput.java

@@ -23,6 +23,7 @@
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 import com.google.analytics.data.v1beta.DateRange;
 import com.google.analytics.data.v1beta.Dimension;
@@ -650,5 +651,5 @@ public int getExpectedTotalPlainRowCount() {
 	public int getFetchSize() {
 		return fetchSize;
 	}
-	
+
 }