fixed synchronized in Connection

Author: Mark

src/main/java/com/arangodb/internal/velocystream/Connection.java

@@ -71,7 +71,7 @@ protected Connection(final String host, final Integer port, final Integer timeou
 		this.sslContext = sslContext;
 	}
 
-	public synchronized boolean isOpen() {
+	public boolean isOpen() {
 		return socket != null && socket.isConnected() && !socket.isClosed();
 	}
 
@@ -126,7 +126,7 @@ public synchronized void close() {
 		}
 	}
 
-	private void sendProtocolHeader() throws IOException {
+	private synchronized void sendProtocolHeader() throws IOException {
 		if (LOGGER.isDebugEnabled()) {
 			LOGGER.debug(String.format("Send velocystream protocol header to %s", socket));
 		}
@@ -162,7 +162,7 @@ protected synchronized void writeIntern(final Message message, final Collection<
 		}
 	}
 
-	private void writeChunkHead(final Chunk chunk) throws IOException {
+	private synchronized void writeChunkHead(final Chunk chunk) throws IOException {
 		final long messageLength = chunk.getMessageLength();
 		final int headLength = messageLength > -1L ? ArangoDBConstants.CHUNK_MAX_HEADER_SIZE
 				: ArangoDBConstants.CHUNK_MIN_HEADER_SIZE;
@@ -205,7 +205,7 @@ private ByteBuffer readBytes(final int len) throws IOException {
 		return ByteBuffer.wrap(buf).order(ByteOrder.LITTLE_ENDIAN);
 	}
 
-	protected void readBytesIntoBuffer(final byte[] buf, final int off, final int len) throws IOException {
+	protected synchronized void readBytesIntoBuffer(final byte[] buf, final int off, final int len) throws IOException {
 		for (int readed = 0; readed < len;) {
 			final int read = inputStream.read(buf, off + readed, len - readed);
 			if (read == -1) {

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 synchronized Message write(final Message message, final Collection<Chunk> chunks) throws ArangoDBException {
+	public Message write(final Message message, final Collection<Chunk> chunks) throws ArangoDBException {
 		super.writeIntern(message, chunks);
 		byte[] chunkBuffer = null;
 		int off = 0;