Author: tabish
Date: Tue Nov 12 22:59:57 2013
New Revision: 1541299
URL: http://svn.apache.org/r1541299
Log:
https://issues.apache.org/jira/browse/AMQNET-458
Adds some command classes.
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNACK.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNECT.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/DISCONNECT.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGREQ.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGRESP.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBACK.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBLISH.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREC.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREL.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBACK.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBSCRIBE.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBACK.cs
(with props)
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBSCRIBE.cs
(with props)
Modified:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/ConnectionFactory.cs
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/vs2008-mqtt.csproj
Modified:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/ConnectionFactory.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/ConnectionFactory.cs?rev=1541299&r1=1541298&r2=1541299&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/ConnectionFactory.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/ConnectionFactory.cs
Tue Nov 12 22:59:57 2013
@@ -47,7 +47,6 @@ namespace Apache.NMS.MQTT
private AcknowledgementMode acknowledgementMode =
AcknowledgementMode.AutoAcknowledge;
private IRedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
- private PrefetchPolicy prefetchPolicy = new PrefetchPolicy();
static ConnectionFactory()
{
@@ -248,12 +247,6 @@ namespace Apache.NMS.MQTT
set { this.acknowledgementMode = value; }
}
- public PrefetchPolicy PrefetchPolicy
- {
- get { return this.prefetchPolicy; }
- set { this.prefetchPolicy = value; }
- }
-
public IRedeliveryPolicy RedeliveryPolicy
{
get { return this.redeliveryPolicy; }
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNACK.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNACK.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNACK.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNACK.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,37 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Command
+{
+ public class CONNACK
+ {
+ public const byte TYPE = 2;
+
+ private byte returnCode;
+ public byte ReturnCode
+ {
+ get { return this.returnCode; }
+ set { this.returnCode = value; }
+ }
+
+ public CONNACK()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNACK.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNECT.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNECT.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNECT.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNECT.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,101 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ /// <summary>
+ /// Connection initiation command sent from client to server.
+ ///
+ /// The payload contains one or more UTF-8 encoded strings. They
specify a unqiue
+ /// identifier for the client, a Will topic and message and the User Name
and Password
+ /// to use. All but the first are optional and their presence is
determined based on flags
+ /// in the variable header.
+ /// </summary>
+ public class CONNECT
+ {
+ public const byte TYPE = 1;
+
+ private byte version = 3;
+ public byte Version
+ {
+ get { return this.version; }
+ set { this.version = value; }
+ }
+
+ private bool willRetain;
+ public bool WillRetain
+ {
+ get { return this.willRetain; }
+ set { this.willRetain = value; }
+ }
+
+ private byte willQoS = 3;
+ public byte WillQoS
+ {
+ get { return this.willQoS; }
+ set { this.willQoS = value; }
+ }
+
+ private String username;
+ public String UserName
+ {
+ get { return this.username; }
+ set { this.username = value; }
+ }
+
+ private String password;
+ public String Password
+ {
+ get { return this.password; }
+ set { this.password = value; }
+ }
+
+ private bool cleanSession;
+ public bool CleanSession
+ {
+ get { return this.cleanSession; }
+ set { this.cleanSession = value; }
+ }
+
+ private short keepAliveTimer = 10;
+ public bool KeepAliveTimer
+ {
+ get { return this.keepAliveTimer; }
+ set { this.keepAliveTimer = value; }
+ }
+
+ private String willTopic;
+ public String WillTopic
+ {
+ get { return this.willTopic; }
+ set { this.willTopic = value; }
+ }
+
+ private String willMessage;
+ public String WillMessage
+ {
+ get { return this.willMessage; }
+ set { this.willMessage = value; }
+ }
+
+ public CONNECT()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/CONNECT.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/DISCONNECT.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/DISCONNECT.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/DISCONNECT.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/DISCONNECT.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class DISCONNECT
+ {
+ public const byte TYPE = 14;
+
+ public DISCONNECT()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/DISCONNECT.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGREQ.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGREQ.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGREQ.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGREQ.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class PINGREQ
+ {
+ public const byte TYPE = 11;
+
+ public PINGREQ()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGREQ.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGRESP.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGRESP.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGRESP.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGRESP.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class PINGRESP
+ {
+ public const byte TYPE = 13;
+
+ public PINGRESP()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PINGRESP.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
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=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBACK.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBACK.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class PUBACK
+ {
+ public const byte TYPE = 4;
+
+ public PUBACK()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBACK.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBLISH.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBLISH.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBLISH.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBLISH.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,81 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ /// <summary>
+ /// The payload part of a PUBLISH message contains application-specific
data only. No
+ /// assumptions are made about the nature or content of the data, and this
part of the
+ /// message is treated as a BLOB.
+ ///
+ /// If you want an application to apply compression to the payload data,
you need to define
+ /// in the application the appropriate payload flag fields to handle the
compression details.
+ /// You cannot define application-specific flags in the fixed or variable
headers.
+ /// </summary>
+ public class PUBLISH
+ {
+ public const byte TYPE = 3;
+
+ private byte qosLevel;
+ public byte QoSLevel
+ {
+ get { return this.qosLevel; }
+ set { this.qosLevel = value; }
+ }
+
+ private bool duplicate;
+ public bool Duplicate
+ {
+ get { return this.duplicate; }
+ set { this.duplicate = value; }
+ }
+
+ private bool retain;
+ public bool Retain
+ {
+ get { return this.retain; }
+ set { this.retain = value; }
+ }
+
+ private short messageId;
+ public short MessageId
+ {
+ get { return this.messageId; }
+ set { this.messageId = value; }
+ }
+
+ private String topicName;
+ public String TopicName
+ {
+ get { return this.topicName; }
+ set { this.topicName = value; }
+ }
+
+ private byte[] payload;
+ public byte[] Payload
+ {
+ get { return this.payload; }
+ set { this.payload = value; }
+ }
+
+ public PUBLISH()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBLISH.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREC.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREC.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREC.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREC.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class PUBREC
+ {
+ public const byte TYPE = 5;
+
+ public PUBREC()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREC.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREL.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREL.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREL.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREL.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class PUBREL
+ {
+ public const byte TYPE = 6;
+
+ public PUBREL()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/PUBREL.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
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=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBACK.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBACK.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,36 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ /// <summary>
+ /// The payload contains a list of granted QoS levels. These are the
QoS levels at
+ /// which the administrators for the server have permitted the client
to subscribe to a
+ /// 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
+ {
+ public const byte TYPE = 8;
+
+ public SUBACK()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBACK.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBSCRIBE.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBSCRIBE.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBSCRIBE.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBSCRIBE.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,34 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ /// <summary>
+ /// The payload contains a list of topic names to which the client can
subscribe, and
+ /// the QoS level. These strings are UTF-encoded.
+ /// </summary>
+ public class SUBSCRIBE
+ {
+ public const byte TYPE = 7;
+
+ public SUBSCRIBE()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/SUBSCRIBE.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
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=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBACK.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBACK.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class UNSUBACK
+ {
+ public const byte TYPE = 10;
+
+ public UNSUBACK()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBACK.cs
------------------------------------------------------------------------------
svn:eol-style = native
Added:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBSCRIBE.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBSCRIBE.cs?rev=1541299&view=auto
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBSCRIBE.cs
(added)
+++
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBSCRIBE.cs
Tue Nov 12 22:59:57 2013
@@ -0,0 +1,30 @@
+//
+// Licensed to the Apache Software Foundation (ASF) under one or more
+// contributor license agreements. See the NOTICE file distributed with
+// this work for additional information regarding copyright ownership.
+// The ASF licenses this file to You under the Apache License, Version 2.0
+// (the "License"); you may not use this file except in compliance with
+// the License. You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+using System;
+
+namespace Apache.NMS.MQTT.Commands
+{
+ public class UNSUBSCRIBE
+ {
+ public const byte TYPE = 9;
+
+ public UNSUBSCRIBE()
+ {
+ }
+ }
+}
+
Propchange:
activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/src/main/csharp/commands/UNSUBSCRIBE.cs
------------------------------------------------------------------------------
svn:eol-style = native
Modified: activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/vs2008-mqtt.csproj
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/vs2008-mqtt.csproj?rev=1541299&r1=1541298&r2=1541299&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/vs2008-mqtt.csproj (original)
+++ activemq/activemq-dotnet/Apache.NMS.MQTT/trunk/vs2008-mqtt.csproj Tue Nov
12 22:59:57 2013
@@ -39,9 +39,23 @@
<ItemGroup>
<Compile Include="src\main\csharp\ConnectionFactory.cs" />
<Compile Include="src\main\csharp\ConnectionMetaData.cs" />
+ <Compile Include="src\main\csharp\commands\CONNECT.cs" />
+ <Compile Include="src\main\csharp\commands\CONNACK.cs" />
+ <Compile Include="src\main\csharp\commands\PUBLISH.cs" />
+ <Compile Include="src\main\csharp\commands\PUBACK.cs" />
+ <Compile Include="src\main\csharp\commands\PUBREC.cs" />
+ <Compile Include="src\main\csharp\commands\PUBREL.cs" />
+ <Compile Include="src\main\csharp\commands\SUBSCRIBE.cs" />
+ <Compile Include="src\main\csharp\commands\SUBACK.cs" />
+ <Compile Include="src\main\csharp\commands\UNSUBSCRIBE.cs" />
+ <Compile Include="src\main\csharp\commands\UNSUBACK.cs" />
+ <Compile Include="src\main\csharp\commands\PINGREQ.cs" />
+ <Compile Include="src\main\csharp\commands\PINGRESP.cs" />
+ <Compile Include="src\main\csharp\commands\DISCONNECT.cs" />
</ItemGroup>
<ItemGroup>
<Folder Include="keyfile\" />
+ <Folder Include="src\main\csharp\commands\" />
</ItemGroup>
<ItemGroup>
<None Include="LICENSE.txt" />
