You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/10/23 21:15:34 UTC
svn commit: r1401397 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java
Author: tabish
Date: Tue Oct 23 19:15:34 2012
New Revision: 1401397
URL: http://svn.apache.org/viewvc?rev=1401397&view=rev
Log:
fix and test for: https://issues.apache.org/jira/browse/AMQ-4106
NIO based transports weren't updating the receive counter in the TcpTransport which can lead to the inactivity monitor mistakenly shutting down the connection.
Forgot one.
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java?rev=1401397&r1=1401396&r2=1401397&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mqtt/MQTTNIOTransport.java Tue Oct 23 19:15:34 2012
@@ -27,6 +27,7 @@ import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;
import javax.net.SocketFactory;
+
import org.apache.activemq.transport.nio.NIOOutputStream;
import org.apache.activemq.transport.nio.SelectorManager;
import org.apache.activemq.transport.nio.SelectorSelection;
@@ -103,9 +104,10 @@ public class MQTTNIOTransport extends Tc
DataByteArrayInputStream dis = new DataByteArrayInputStream(inputBuffer.array());
codec.parse(dis, readSize);
+ receiveCounter += readSize;
+
// clear the buffer
inputBuffer.clear();
-
}
} catch (IOException e) {
onException(e);