问向IoTHub发送消息失败

EN

public static class Mqtt2IoTNew
{
    private static string _DeviceConnectionString = Properties.Settings.Default.MqttUri;

    private static TransportType _TransportType = TransportType.Mqtt_WebSocket_Only;

   public static void Send(object argEntry, bool argIsList)
    {
        var deviceClient = DeviceClient.CreateFromConnectionString(_DeviceConnectionString, _TransportType);
        deviceClient.ReceiveAsync(TimeSpan.FromSeconds(2)).Wait();

        var message = new Message(deviceClient, argEntry, argIsList);
        message.RunAsync().GetAwaiter().GetResult();
    }

}

internal class Message
{
    private DeviceClient _DeviceClient;
    private readonly string _Message;

    public Message(DeviceClient argDeviceClient, object argEntry, bool isList)
    {
        _DeviceClient = argDeviceClient;
        StringBuilder stb = new StringBuilder();
        if (isList)
        {
            foreach (var entity in (List<object>) argEntry)
            {
                stb.Append("<entity>").Append(JsonConvert.SerializeObject(entity)).Append("</entity>\n");
            }
        }
        else
        {
            stb.Append(JsonConvert.SerializeObject(argEntry));
        }
        _Message = stb.ToString();
    }

    public async Task RunAsync()
    {
        await SendEvent().ConfigureAwait(false);
    }

    private async Task SendEvent()
    {
        Microsoft.Azure.Devices.Client.Message eventMessage = new Microsoft.Azure.Devices.Client.Message(Encoding.UTF8.GetBytes(_Message));
        await _DeviceClient.SendEventAsync(eventMessage).ConfigureAwait(false);
    }
}



//Call of method that does not work
    protected override void DoOnCompleted(IRepository argRepository)
    {
        if (_CurrentlySendingTreadId.HasValue)
        {
            if (_CurrentlySendingTreadId.Value == Thread.CurrentThread.ManagedThreadId)
            {
                return;
            }
        }

        TaskFactoryProvider.GetFactory().StartNew(()=>SendBatchProtocols());
    }

    public bool SendBatchProtocols()
    {
        using (var repository = RepositoryProviderHolder.RepositoryProvider.GetRepository(Constants.CONTAINERCONTRACT_PRODUCTIONREPOSITORY))
        {
            IQueryable<BatchProtocol> batchProtocolQuery = repository.GetQuery<BatchProtocol>().OrderBy(bp => bp.InternalNoInteger);
            batchProtocolQuery = batchProtocolQuery.Where(bp => !bp.IsArchived).Take(1);

            if (!batchProtocolQuery.Any()) return false;

            var batchProtocols = batchProtocolQuery.ToList();
            IsBatchProtocolSend = false;
            try
            {
                foreach (var bps in batchProtocols)
                {
                    Mqtt2IoTNew.Send(bps,false);
                }
                IsBatchProtocolSend = true;
            }
            catch (Exception ex)
            {
                throw;
            }
        }
        return IsBatchProtocolSend;
    }

//Call of Method that does work
    private void AddEntitiesAndSaveChanges(IEnumerable argEntities)
    {
        if (argEntities == null)
        {
            return;
        }

        lock (_UnderlyingRepositoryAccessLockObject)
        {
            #region Log2DornerIoT


            if (Properties.Settings.Default.Log2DornerIoT)
            {
                List<object> entities = new List<object>();
                int i = 0;
                foreach (var entity in argEntities)
                {
                    if (i < 100)
                    {
                        entities.Add(entity);
                        i++;
                    }
                    else
                    {
                        try
                        {
                            Mqtt2IoTNew.Send(entities, true);
                        }
                        catch (Exception e)
                        {
                            throw;
                        }
                        entities.Clear();
                        i = 0;
                    }
                }
            }
        }