Merge pull request #11 from kr-pawan/master

DEPL-12726 - added shutdown method to shutdown executor service

metrics-influxdb/src/main/java/com/tqdev/metrics/influxdb/InfluxDbReporter.java

@@ -41,6 +41,8 @@ abstract class InfluxDbReporter {
 	 */
 	protected final MetricRegistry registry;
 
+	private final ScheduledExecutorService exec;
+
 	/**
 	 * Instantiates a new JMX reporter.
 	 *
@@ -54,6 +56,7 @@ abstract class InfluxDbReporter {
 	public InfluxDbReporter(MetricRegistry registry, String instanceName) {
 		this.instanceName = instanceName;
 		this.registry = registry;
+		this.exec = Executors.newSingleThreadScheduledExecutor();
 	}
 
 	/**
@@ -101,7 +104,13 @@ public void write(OutputStream out) {
 	 *            the interval in seconds
 	 */
 	public void run(int intervalInSeconds) {
-		ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor();
 		exec.scheduleAtFixedRate(() -> this.report(), 1, intervalInSeconds, TimeUnit.SECONDS);
 	}
-}
+
+	/**
+	 * Handler for shutdown of Executor service.
+	 */
+	public void shutdown() {
+		this.exec.shutdown();
+	}
+}