Close client after potential batch flush.

asashour · asashour · commit 77b64bd5cf1a · 2019-02-01T11:09:34.000+01:00
diff --git a/src/main/java/org/influxdb/impl/InfluxDBImpl.java b/src/main/java/org/influxdb/impl/InfluxDBImpl.java
@@ -828,15 +828,15 @@ public void flush() {
    */
   @Override
   public void close() {
-    this.client.dispatcher().executorService().shutdown();
-    this.client.connectionPool().evictAll();
     try {
         this.disableBatch();
     } finally {
         if (datagramSocket != null && !datagramSocket.isClosed()) {
             datagramSocket.close();
         }
     }
+    this.client.dispatcher().executorService().shutdown();
+    this.client.connectionPool().evictAll();
   }
 
   @Override

Original file line number	Diff line number	Diff line change
`@@ -828,15 +828,15 @@ public void flush() {`
`828`	`828`	`*/`
`829`	`829`	`@Override`
`830`	`830`	`public void close() {`
`831`		`- this.client.dispatcher().executorService().shutdown();`
`832`		`- this.client.connectionPool().evictAll();`
`833`	`831`	`try {`
`834`	`832`	`this.disableBatch();`
`835`	`833`	`} finally {`
`836`	`834`	`if (datagramSocket != null && !datagramSocket.isClosed()) {`
`837`	`835`	`datagramSocket.close();`
`838`	`836`	`}`
`839`	`837`	`}`
	`838`	`+ this.client.dispatcher().executorService().shutdown();`
	`839`	`+ this.client.connectionPool().evictAll();`
`840`	`840`	`}`
`841`	`841`
`842`	`842`	`@Override`