[jboss-cvs] JBoss Messaging SVN: r3684 - in trunk: tests/src/org/jboss/messaging/core/remoting/wireformat/test/unit and 1 other directory.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri Feb 8 10:07:27 EST 2008
Author: jmesnil
Date: 2008-02-08 10:07:26 -0500 (Fri, 08 Feb 2008)
New Revision: 3684
Modified:
trunk/src/main/org/jboss/messaging/core/remoting/codec/ConsumerFlowTokenMessageCodec.java
trunk/tests/src/org/jboss/messaging/core/remoting/wireformat/test/unit/PacketTypeTest.java
Log:
* in PacketTypeTest, renamed testChangeRateMessage() to testConsumerFlowTokenMessage()
* fixed encoding in ConsumerFlowTokenMessageCodec
Modified: trunk/src/main/org/jboss/messaging/core/remoting/codec/ConsumerFlowTokenMessageCodec.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/remoting/codec/ConsumerFlowTokenMessageCodec.java 2008-02-08 14:29:14 UTC (rev 3683)
+++ trunk/src/main/org/jboss/messaging/core/remoting/codec/ConsumerFlowTokenMessageCodec.java 2008-02-08 15:07:26 UTC (rev 3684)
@@ -37,7 +37,7 @@
protected void encodeBody(ConsumerFlowTokenMessage message, RemotingBuffer out) throws Exception
{
out.putInt(INT_LENGTH);
- out.putFloat(message.getTokens());
+ out.putInt(message.getTokens());
}
@Override
Modified: trunk/tests/src/org/jboss/messaging/core/remoting/wireformat/test/unit/PacketTypeTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/core/remoting/wireformat/test/unit/PacketTypeTest.java 2008-02-08 14:29:14 UTC (rev 3683)
+++ trunk/tests/src/org/jboss/messaging/core/remoting/wireformat/test/unit/PacketTypeTest.java 2008-02-08 15:07:26 UTC (rev 3684)
@@ -655,7 +655,7 @@
assertEquals(CONN_STOP, decodedPacket.getType());
}
- public void testChangeRateMessage() throws Exception
+ public void testConsumerFlowTokenMessage() throws Exception
{
ConsumerFlowTokenMessage message = new ConsumerFlowTokenMessage(10);
AbstractPacketCodec codec = new ConsumerFlowTokenMessageCodec();
More information about the jboss-cvs-commits
mailing list