MqttSubscribePacket.cs 765 B

123456789101112131415161718192021222324
  1. using System.Collections.Generic;
  2. using System.Linq;
  3. namespace MQTTnet.Packets
  4. {
  5. public class MqttSubscribePacket : MqttBasePacket, IMqttPacketWithIdentifier
  6. {
  7. public ushort? PacketIdentifier { get; set; }
  8. public List<MqttTopicFilter> TopicFilters { get; set; } = new List<MqttTopicFilter>();
  9. #region Added in MQTTv5
  10. public MqttSubscribePacketProperties Properties { get; set; }
  11. #endregion
  12. public override string ToString()
  13. {
  14. var topicFiltersText = string.Join(",", TopicFilters.Select(f => f.Topic + "@" + f.QualityOfServiceLevel));
  15. return string.Concat("Subscribe: [PacketIdentifier=", PacketIdentifier, "] [TopicFilters=", topicFiltersText, "]");
  16. }
  17. }
  18. }