Author: rajith
Date: Mon Dec 3 09:13:22 2007
New Revision: 600599
URL: http://svn.apache.org/viewvc?rev=600599&view=rev
Log:
fixed the error in receiving
Modified:
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java
Modified:
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java?rev=600599&r1=600598&r2=600599&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java
(original)
+++
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/nio/NioHandler.java
Mon Dec 3 09:13:22 2007
@@ -84,7 +84,7 @@
public void run()
{
- _readBuf = ByteBuffer.allocate(1024);
+ _readBuf = ByteBuffer.allocate(512);
long read = 0;
while(_ch.isConnected() && _ch.isOpen())
{
@@ -93,10 +93,12 @@
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)
