diff options
Diffstat (limited to 'plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java')
-rw-r--r-- | plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java | 17 |
1 files changed, 12 insertions, 5 deletions
diff --git a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java index b86f6dd4db..db1cfa94b3 100644 --- a/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java +++ b/plugins/org.eclipse.net4j.http/src/org/eclipse/net4j/internal/http/HTTPClientConnector.java @@ -83,14 +83,21 @@ public class HTTPClientConnector extends HTTPConnector { public void handleOut(ExtendedDataOutputStream out) throws IOException { - buffer.flip(); - ByteBuffer byteBuffer = buffer.getByteBuffer(); - byte[] data = byteBuffer.array(); - out.writeByte(INet4jTransportServlet.OPCODE_SEND_BUFFER); out.writeString(getConnectorID()); out.writeShort(channel.getChannelIndex()); - out.writeByteArray(data); + + buffer.flip(); + ByteBuffer byteBuffer = buffer.getByteBuffer(); + byteBuffer.position(IBuffer.HEADER_SIZE); + int length = byteBuffer.limit() - byteBuffer.position(); + out.writeShort(length); + for (int i = 0; i < length; i++) + { + byte b = byteBuffer.get(); + System.out.println("Payload: " + b); + out.writeByte(b); + } buffer.release(); } |