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 2013/11/27 20:10:47 UTC
svn commit: r1546163 - in
/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands:
PUBACK.cs SUBACK.cs UNSUBACK.cs
Author: tabish
Date: Wed Nov 27 19:10:47 2013
New Revision: 1546163
URL: http://svn.apache.org/r1546163
Log:
https://issues.apache.org/jira/browse/AMQNET-458
Implementation
Modified:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/PUBACK.cs
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/SUBACK.cs
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/UNSUBACK.cs
Modified: activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/PUBACK.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/PUBACK.cs?rev=1546163&r1=1546162&r2=1546163&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/PUBACK.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/PUBACK.cs Wed Nov 27 19:10:47 2013
@@ -21,7 +21,7 @@ using Apache.NMS.MQTT.Protocol;
namespace Apache.NMS.MQTT.Commands
{
- public class PUBACK : BaseCommand
+ public class PUBACK : Response
{
public const byte TYPE = 4;
public const byte DEFAULT_HEADER = 0x40;
@@ -43,6 +43,16 @@ namespace Apache.NMS.MQTT.Commands
{
get { return true; }
}
+
+ public override void Encode(BinaryWriter writer)
+ {
+ writer.Write(CommandId);
+ }
+
+ public override void Decode(BinaryReader reader)
+ {
+ CorrelationId = reader.ReadInt16();
+ }
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/SUBACK.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/SUBACK.cs?rev=1546163&r1=1546162&r2=1546163&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/SUBACK.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/SUBACK.cs Wed Nov 27 19:10:47 2013
@@ -27,7 +27,7 @@ namespace Apache.NMS.MQTT.Commands
/// particular Topic Name. Granted QoS levels are listed in the same order as the topic
/// names in the corresponding SUBSCRIBE message.
/// </summary>
- public class SUBACK : BaseCommand
+ public class SUBACK : Response
{
public const byte TYPE = 9;
public const byte DEFAULT_HEADER = 0x90;
@@ -49,6 +49,16 @@ namespace Apache.NMS.MQTT.Commands
{
get { return true; }
}
+
+ public override void Encode(BinaryWriter writer)
+ {
+ writer.Write(CommandId);
+ }
+
+ public override void Decode(BinaryReader reader)
+ {
+ CorrelationId = reader.ReadInt16();
+ }
}
}
Modified: activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/UNSUBACK.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/UNSUBACK.cs?rev=1546163&r1=1546162&r2=1546163&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/UNSUBACK.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands/UNSUBACK.cs Wed Nov 27 19:10:47 2013
@@ -21,7 +21,7 @@ using Apache.NMS.MQTT.Protocol;
namespace Apache.NMS.MQTT.Commands
{
- public class UNSUBACK : BaseCommand
+ public class UNSUBACK : Response
{
public const byte TYPE = 11;
public const byte DEFAULT_HEADER = 0xB0;
@@ -43,6 +43,16 @@ namespace Apache.NMS.MQTT.Commands
{
get { return true; }
}
+
+ public override void Encode(BinaryWriter writer)
+ {
+ writer.Write(CommandId);
+ }
+
+ public override void Decode(BinaryReader reader)
+ {
+ CorrelationId = reader.ReadInt16();
+ }
}
}