Class PollingTelemetryConnectorWorker

Namespace

Azure.Iot.Operations.Connector

Assembly

Azure.Iot.Operations.Connector.dll

public class PollingTelemetryConnectorWorker : ConnectorWorker, IHostedService, IDisposable

Inheritance

object

BackgroundService

ConnectorBackgroundService

ConnectorWorker

PollingTelemetryConnectorWorker

Implements

IHostedService

IDisposable

Inherited Members

ConnectorWorker._logger

ConnectorWorker._adrClient

ConnectorWorker.WhileDeviceIsAvailable

ConnectorWorker.WhileAssetIsAvailable

ConnectorWorker.RunConnectorAsync(CancellationToken)

ConnectorWorker.ExecuteAsync(CancellationToken)

ConnectorWorker.GetRegisteredDatasetMessageSchema(string, string, string, string)

ConnectorWorker.GetRegisteredEventMessageSchema(string, string, string, string, string)

ConnectorWorker.Dispose()

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<ConnectorWorker>, IMqttClient, IDatasetSamplerFactory, IMessageSchemaProvider, IAzureDeviceRegistryClientWrapperProvider, IConnectorLeaderElectionConfigurationProvider?)

public PollingTelemetryConnectorWorker(ApplicationContext applicationContext, ILogger<ConnectorWorker> logger, IMqttClient mqttClient, IDatasetSamplerFactory datasetSamplerFactory, IMessageSchemaProvider messageSchemaFactory, IAzureDeviceRegistryClientWrapperProvider adrClientFactory, IConnectorLeaderElectionConfigurationProvider? leaderElectionConfigurationProvider = null)

Parameters

applicationContext ApplicationContext

logger ILogger<ConnectorWorker>

mqttClient IMqttClient

datasetSamplerFactory IDatasetSamplerFactory

messageSchemaFactory IMessageSchemaProvider

adrClientFactory IAzureDeviceRegistryClientWrapperProvider

leaderElectionConfigurationProvider IConnectorLeaderElectionConfigurationProvider

Methods

WhileAssetAvailableAsync(AssetAvailableEventArgs, CancellationToken)

public Task WhileAssetAvailableAsync(AssetAvailableEventArgs args, CancellationToken cancellationToken)

Parameters

args AssetAvailableEventArgs

cancellationToken CancellationToken

Returns

Task

WhileDeviceAvailableAsync(DeviceAvailableEventArgs, CancellationToken)

public Task WhileDeviceAvailableAsync(DeviceAvailableEventArgs args, CancellationToken cancellationToken)

Parameters

args DeviceAvailableEventArgs

cancellationToken CancellationToken

Returns

Task