Batch processor keeps data points queued on failed write

pom.xml

@@ -11,7 +11,7 @@
 	<groupId>org.influxdb</groupId>
 	<artifactId>influxdb-java</artifactId>
 	<packaging>jar</packaging>
-	<version>2.0-SNAPSHOT</version>
+	<version>2.1-SS-SNAPSHOT</version>
 	<name>influxdb java bindings</name>
 	<description>Java API to access the InfluxDB REST API</description>
 	<url>http://www.influxdb.org</url>

src/main/java/org/influxdb/InfluxDBFactory.java

@@ -4,6 +4,8 @@
 import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 
+import java.util.concurrent.TimeUnit;
+
 /**
  * A Factory to create a instance of a InfluxDB Database adapter.
  * 
@@ -25,9 +27,29 @@ public enum InfluxDBFactory {
 	 * @return a InfluxDB adapter suitable to access a InfluxDB.
 	 */
 	public static InfluxDB connect(final String url, final String username, final String password) {
+		return connect(url, username, password, 0, null);
+	}
+
+	/**
+	 * Create a connection to a InfluxDB.
+	 *
+	 * @param url
+	 *            the url to connect to.
+	 * @param username
+	 *            the username which is used to authorize against the influxDB instance.
+	 * @param password
+	 *            the password for the username which is used to authorize against the influxDB
+	 *            instance.
+	 * @param networkTimeout
+	 *            the period of time to try to connect to the influxDB database
+	 * @param timeoutTimeUnit
+	 *            the unit of time that the network timeout parameter is measured
+	 * @return a InfluxDB adapter suitable to access a InfluxDB.
+	 */
+	public static InfluxDB connect(final String url, final String username, final String password, final long networkTimeout, final TimeUnit timeoutTimeUnit) {
 		Preconditions.checkArgument(!Strings.isNullOrEmpty(url), "The URL may not be null or empty.");
 		Preconditions.checkArgument(!Strings.isNullOrEmpty(username), "The username may not be null or empty.");
-		return new InfluxDBImpl(url, username, password);
+		return new InfluxDBImpl(url, username, password, networkTimeout, timeoutTimeUnit);
 	}
 
 }

src/main/java/org/influxdb/dto/Point.java

@@ -265,6 +265,13 @@ public String lineProtocol() {
 		return sb.toString();
 	}
 
+	/**
+	 * Gets the time related to the Point
+	 *
+	 * @return The time related to the Point
+	 */
+	public Long getTime(){return time;}
+
 	private StringBuilder concatenatedTags() {
 		final StringBuilder sb = new StringBuilder();
 		for (Entry<String, String> tag : this.tags.entrySet()) {

src/main/java/org/influxdb/impl/BatchEntry.java

@@ -0,0 +1,31 @@
+package org.influxdb.impl;
+
+import org.influxdb.dto.Point;
+
+/**
+ * Created by Paul on 11/17/2015.
+ */
+public class BatchEntry {
+    private final Point point;
+    private final String db;
+    private final String rp;
+
+    public BatchEntry(final Point point, final String db, final String rp) {
+        super();
+        this.point = point;
+        this.db = db;
+        this.rp = rp;
+    }
+
+    public Point getPoint() {
+        return this.point;
+    }
+
+    public String getDb() {
+        return this.db;
+    }
+
+    public String getRp() {
+        return this.rp;
+    }
+}