svn commit: r1546163 - in /activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/Commands: PUBACK.cs SUBACK.cs UNSUBACK.cs

[tabish]

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();
+        }
        }
 }