fixed issue with streamwriter

Author: jruaux

pom.xml

@@ -12,7 +12,7 @@
 
 	<groupId>com.redislabs</groupId>
 	<artifactId>riot</artifactId>
-	<version>0.3.0</version>
+	<version>0.4.1</version>
 	<packaging>jar</packaging>
 	<name>RIOT</name>
 	<description>Redis Input/Output Tool</description>

src/main/java/com/redislabs/riot/redis/writer/StreamWriter.java

@@ -26,14 +26,17 @@ protected void write(Pipeline pipeline, String key, Map<String, Object> item) {
 		if (idField == null) {
 			if (maxlen == null) {
 				pipeline.xadd(key, new StreamEntryID(), fields);
+			} else {
+				pipeline.xadd(key, new StreamEntryID(), fields, maxlen, approximateTrimming);
+			}
+		} else {
+			String id = id(item);
+			if (maxlen == null) {
+				pipeline.xadd(key, new StreamEntryID(id), fields);
+			} else {
+				pipeline.xadd(key, new StreamEntryID(id), fields, maxlen, approximateTrimming);
 			}
-			pipeline.xadd(key, new StreamEntryID(), fields, maxlen, approximateTrimming);
-		}
-		String id = id(item);
-		if (maxlen == null) {
-			pipeline.xadd(key, new StreamEntryID(id), fields);
 		}
-		pipeline.xadd(key, new StreamEntryID(id), fields, maxlen, approximateTrimming);
 	}
 
 	@Override