Class MqttChannelAdapter

Namespace

MQTTnet.Adapter

Assembly

MQTTnet.dll

public sealed class MqttChannelAdapter : Disposable, IMqttChannelAdapter, IDisposable

Inheritance

object

Disposable

MqttChannelAdapter

Implements

IMqttChannelAdapter

IDisposable

Inherited Members

Disposable.Dispose()

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

MqttChannelAdapter(IMqttChannel, MqttPacketFormatterAdapter, IMqttNetLogger)

public MqttChannelAdapter(IMqttChannel channel, MqttPacketFormatterAdapter packetFormatterAdapter, IMqttNetLogger logger)

Parameters

channel IMqttChannel

packetFormatterAdapter MqttPacketFormatterAdapter

logger IMqttNetLogger

Properties

AllowPacketFragmentation

public bool AllowPacketFragmentation { get; set; }

Property Value

bool

BytesReceived

public long BytesReceived { get; }

Property Value

long

BytesSent

public long BytesSent { get; }

Property Value

long

ClientCertificate

public X509Certificate2 ClientCertificate { get; }

Property Value

X509Certificate2

Endpoint

public string Endpoint { get; }

Property Value

string

IsSecureConnection

public bool IsSecureConnection { get; }

Property Value

bool

PacketFormatterAdapter

public MqttPacketFormatterAdapter PacketFormatterAdapter { get; }

Property Value

MqttPacketFormatterAdapter

PacketInspector

public MqttPacketInspector PacketInspector { get; set; }

Property Value

MqttPacketInspector

Methods

ConnectAsync(CancellationToken)

public Task ConnectAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

DisconnectAsync(CancellationToken)

public Task DisconnectAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task

Dispose(bool)

protected override void Dispose(bool disposing)

Parameters

disposing bool

ReceivePacketAsync(CancellationToken)

public Task<MqttPacket> ReceivePacketAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Returns

Task<MqttPacket>

ResetStatistics()

public void ResetStatistics()

SendPacketAsync(MqttPacket, CancellationToken)

public Task SendPacketAsync(MqttPacket packet, CancellationToken cancellationToken)

Parameters

packet MqttPacket

cancellationToken CancellationToken

Returns

Task