/* Code generated by Azure.Iot.Operations.ProtocolCompilerLib v1.0.0.0; DO NOT EDIT. */

#nullable enable

using System;
using System.Collections.Generic;
using System.Linq;
using System.Xml;
using Azure.Iot.Operations.Protocol;
using Azure.Iot.Operations.Protocol.RPC;
using Azure.Iot.Operations.Protocol.Models;
using Azure.Iot.Operations.Services.AssetAndDeviceRegistry.Generated.Common;

namespace Azure.Iot.Operations.Services.AssetAndDeviceRegistry.Generated.AdrBaseService
{
    public static partial class AdrBaseService
    {
        /// <summary>
        /// Specializes a <c>CommandExecutor</c> class for Command 'setNotificationPreferenceForAssetUpdates'.
        /// </summary>
        [CommandTopic("akri/connector/resources/{ex:connectorClientId}/{ex:deviceName}/{ex:inboundEndpointName}/setNotificationPreferenceForAssetUpdates")]
        public class SetNotificationPreferenceForAssetUpdatesCommandExecutor : CommandExecutor<SetNotificationPreferenceForAssetUpdatesRequestPayload, SetNotificationPreferenceForAssetUpdatesResponseSchema>
        {
            /// <summary>
            /// Initializes a new instance of the <see cref="SetNotificationPreferenceForAssetUpdatesCommandExecutor"/> class.
            /// </summary>
            public SetNotificationPreferenceForAssetUpdatesCommandExecutor(ApplicationContext applicationContext, IMqttPubSubClient mqttClient)
                : base(applicationContext, mqttClient, "setNotificationPreferenceForAssetUpdates", new Utf8JsonSerializer())
            {
                if (mqttClient.ClientId != null)
                {
                    TopicTokenMap["executorId"] = mqttClient.ClientId;
                }
            }
        }
    }
}
