fixed synchronized

Mark · Mark · commit e4c4d8e17587 · 2017-02-08T09:36:11.000+01:00
diff --git a/src/main/java/com/arangodb/internal/velocystream/ConnectionSync.java b/src/main/java/com/arangodb/internal/velocystream/ConnectionSync.java
@@ -85,7 +85,7 @@ private ConnectionSync(final String host, final Integer port, final Integer time
 		super(host, port, timeout, useSsl, sslContext);
 	}
 
-	public Message write(final Message message, final Collection<Chunk> chunks) throws ArangoDBException {
+	public synchronized Message write(final Message message, final Collection<Chunk> chunks) throws ArangoDBException {
 		super.writeIntern(message, chunks);
 		byte[] chunkBuffer = null;
 		int off = 0;

Original file line number	Diff line number	Diff line change
`@@ -85,7 +85,7 @@ private ConnectionSync(final String host, final Integer port, final Integer time`
`85`	`85`	`super(host, port, timeout, useSsl, sslContext);`
`86`	`86`	`}`
`87`	`87`
`88`		`- public Message write(final Message message, final Collection<Chunk> chunks) throws ArangoDBException {`
	`88`	`+ public synchronized Message write(final Message message, final Collection<Chunk> chunks) throws ArangoDBException {`
`89`	`89`	`super.writeIntern(message, chunks);`
`90`	`90`	`byte[] chunkBuffer = null;`
`91`	`91`	`int off = 0;`