Есть ли способ отладить QueeTrigger без множественного потока? Я получил несколько сообщений в очереди, и моя программа продолжает джуноваться взад -вперед каждый раз, когда я нажимаю на Contitnue или нажимаю вперед, это очень трудно отслеживать вещи. < /P>
Я пытался Добавить iSbatched = false в качестве параметра запуска и изменение файла хоста, чтобы иметь "maxConcurrentCalls": 1 Но ничего не работает. Я использую Visual Studio < /p>
[Function("ProcessSensorWarningMessages")]
public void Run(
[ServiceBusTrigger("sensor_warningmessagedata", Connection = "ServiceBus-ConnetionString",IsBatched = false)]
ServiceBusReceivedMessage message,
ServiceBusMessageActions messageActions)
{
try
{
_logger.LogInformation("Message ID: {id}", message.MessageId);
_logger.LogInformation("Message Body: {body}", message.Body);
_logger.LogInformation("Message Content-Type: {contentType}", message.ContentType);
SmsServiceTemp smsService = new SmsServiceTemp(_logger);
EmailServiceTemp emailService = new EmailServiceTemp(_logger);
EnviromentVariables.EnviromentConfig(_logger);// fix so program crashes if null
string messageBody = message.Body.ToString(); // change program to use mesage body i dont need controller class here
SensorDatabaseQueryTemp sensorDatabaseQueryTemp = new SensorDatabaseQueryTemp(_logger);
SensorDatabaseQueryLastSeen sensorDatabaseQueryLastSeen = new SensorDatabaseQueryLastSeen(_logger);
SensorDataQueueModel queueData = JsonSerializer.Deserialize(messageBody);
if (queueData.TempId > 0)
{
JoinedSensorDataTemp temp = sensorDatabaseQueryTemp.GetJoinedSensorData(queueData.TempId);
SmsEmailHelperTemp.Warningloop(temp, _logger);
_logger.LogInformation("Successfully sendt Warning");
messageActions.CompleteMessageAsync(message);
}
else if (queueData.LastSeenId > 0)
{
JoinedSensorDataTemp lastSeen = sensorDatabaseQueryLastSeen.GetJoinedSensorData(queueData.LastSeenId);
SmsEmailHelperLastSeen.Warningloop(lastSeen, _logger);
_logger.LogInformation("Successfully sendt Warning");
messageActions.CompleteMessageAsync(message);
}
else
{
//null exception
}
}
catch (JsonException ex)
{
_logger.LogError(ex, "Error deserializing message body.");
messageActions.DeadLetterMessageAsync(message);
}
// Complete the message
}
Подробнее здесь: https://stackoverflow.com/questions/793 ... euetrigger
Отладка с помощью однопоточного лазурного QueeTrigger ⇐ C#
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
OkHttp3 Отладка задержки сети с помощью прослушивателей событий — событие ConnectionReleased
Anonymous » » в форуме JAVA - 0 Ответы
- 33 Просмотры
-
Последнее сообщение Anonymous
-