Class PollingTelemetryConnectorWorker

Namespace

Azure.Iot.Operations.Connector

Assembly

Azure.Iot.Operations.Connector.dll

public class PollingTelemetryConnectorWorker : TelemetryConnectorWorker, IHostedService, IDisposable

Inheritance

object

BackgroundService

ConnectorBackgroundService

TelemetryConnectorWorker

PollingTelemetryConnectorWorker

Implements

IHostedService

IDisposable

Inherited Members

TelemetryConnectorWorker._logger

TelemetryConnectorWorker.OnAssetAvailable

TelemetryConnectorWorker.OnAssetUnavailable

TelemetryConnectorWorker.AssetEndpointProfile

TelemetryConnectorWorker.RunConnectorAsync(CancellationToken)

TelemetryConnectorWorker.ExecuteAsync(CancellationToken)

TelemetryConnectorWorker.ForwardSampledDatasetAsync(Asset, Dataset, byte[], CancellationToken)

TelemetryConnectorWorker.ForwardReceivedEventAsync(Asset, Event, byte[], CancellationToken)

BackgroundService.StartAsync(CancellationToken)

BackgroundService.StopAsync(CancellationToken)

BackgroundService.ExecuteTask

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PollingTelemetryConnectorWorker(ApplicationContext, ILogger<TelemetryConnectorWorker>, IMqttClient, IDatasetSamplerFactory, IMessageSchemaProvider, IAssetMonitor, IConnectorLeaderElectionConfigurationProvider?)

public PollingTelemetryConnectorWorker(ApplicationContext applicationContext, ILogger<TelemetryConnectorWorker> logger, IMqttClient mqttClient, IDatasetSamplerFactory datasetSamplerFactory, IMessageSchemaProvider messageSchemaFactory, IAssetMonitor assetMonitor, IConnectorLeaderElectionConfigurationProvider? leaderElectionConfigurationProvider = null)

Parameters

applicationContext ApplicationContext

logger ILogger<TelemetryConnectorWorker>

mqttClient IMqttClient

datasetSamplerFactory IDatasetSamplerFactory

messageSchemaFactory IMessageSchemaProvider

assetMonitor IAssetMonitor

leaderElectionConfigurationProvider IConnectorLeaderElectionConfigurationProvider

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public override void Dispose()

OnAssetNotSampleableAsync(object?, AssetUnavailableEventArgs)

public void OnAssetNotSampleableAsync(object? sender, AssetUnavailableEventArgs args)

Parameters

sender object

args AssetUnavailableEventArgs

OnAssetSampleableAsync(object?, AssetAvailabileEventArgs)

public void OnAssetSampleableAsync(object? sender, AssetAvailabileEventArgs args)

Parameters

sender object

args AssetAvailabileEventArgs