IMqttDataConverter.cs 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. using MQTTnet.Client.Connecting;
  2. using MQTTnet.Client.Disconnecting;
  3. using MQTTnet.Client.Options;
  4. using MQTTnet.Client.Publishing;
  5. using MQTTnet.Client.Subscribing;
  6. using MQTTnet.Client.Unsubscribing;
  7. using MQTTnet.Packets;
  8. using MQTTnet.Server;
  9. using MqttClientSubscribeResult = MQTTnet.Client.Subscribing.MqttClientSubscribeResult;
  10. namespace MQTTnet.Formatter
  11. {
  12. public interface IMqttDataConverter
  13. {
  14. MqttPublishPacket CreatePublishPacket(MqttApplicationMessage applicationMessage);
  15. MqttPubAckPacket CreatePubAckPacket(MqttPublishPacket publishPacket);
  16. MqttApplicationMessage CreateApplicationMessage(MqttPublishPacket publishPacket);
  17. MqttClientAuthenticateResult CreateClientConnectResult(MqttConnAckPacket connAckPacket);
  18. MqttConnectPacket CreateConnectPacket(MqttApplicationMessage willApplicationMessage, IMqttClientOptions options);
  19. MqttConnAckPacket CreateConnAckPacket(MqttConnectionValidatorContext connectionValidatorContext);
  20. MqttClientSubscribeResult CreateClientSubscribeResult(MqttSubscribePacket subscribePacket, MqttSubAckPacket subAckPacket);
  21. MqttClientUnsubscribeResult CreateClientUnsubscribeResult(MqttUnsubscribePacket unsubscribePacket, MqttUnsubAckPacket unsubAckPacket);
  22. MqttSubscribePacket CreateSubscribePacket(MqttClientSubscribeOptions options);
  23. MqttUnsubscribePacket CreateUnsubscribePacket(MqttClientUnsubscribeOptions options);
  24. MqttDisconnectPacket CreateDisconnectPacket(MqttClientDisconnectOptions options);
  25. MqttClientPublishResult CreatePublishResult(MqttPubAckPacket pubAckPacket);
  26. MqttClientPublishResult CreatePublishResult(MqttPubRecPacket pubRecPacket, MqttPubCompPacket pubCompPacket);
  27. }
  28. }