diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2007-12-03 17:13:22 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2007-12-03 17:13:22 +0000 |
| commit | 63cf3190e4b534fefdbfa8080982f34a49cb8131 (patch) | |
| tree | aee4b15578079f085f7581f71f368e4feb0956e6 /qpid | |
| parent | 065e4b6406c8ab341dfdd84206e7be66a17df060 (diff) | |
| download | qpid-python-63cf3190e4b534fefdbfa8080982f34a49cb8131.tar.gz | |
fixed the error in receiving
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@600599 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java index c5ba3b564d..a7339427c7 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java @@ -84,7 +84,7 @@ public class NioHandler implements Runnable public void run() { - _readBuf = ByteBuffer.allocate(1024); + _readBuf = ByteBuffer.allocate(512); long read = 0; while(_ch.isConnected() && _ch.isOpen()) { @@ -93,10 +93,12 @@ public class NioHandler implements Runnable read = _ch.read(_readBuf); if (read > 0) { - ByteBuffer b = _readBuf; + _readBuf.flip(); + ByteBuffer b = ByteBuffer.allocate(_readBuf.remaining()); + b.put(_readBuf); b.flip(); - _receiver.received(b); _readBuf.clear(); + _receiver.received(b); } } catch(Exception e) |