1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465 |
-
- #if BROKER
- using System.Collections;
- using System.Collections.Generic;
- using uPLibrary.Networking.M2Mqtt.Managers;
- using uPLibrary.Networking.M2Mqtt.Messages;
- namespace uPLibrary.Networking.M2Mqtt.Session
- {
-
-
-
- public class MqttBrokerSession : MqttSession
- {
-
-
-
- public MqttClient Client { get; set; }
-
-
-
- public List<MqttSubscription> Subscriptions;
-
-
-
- public Queue<MqttMsgPublish> OutgoingMessages;
-
-
-
- public MqttBrokerSession()
- : base()
- {
- this.Client = null;
- this.Subscriptions = new List<MqttSubscription>();
- this.OutgoingMessages = new Queue<MqttMsgPublish>();
- }
- public override void Clear()
- {
- base.Clear();
- this.Client = null;
- this.Subscriptions.Clear();
- this.OutgoingMessages.Clear();
- }
- }
- }
- #endif
|