Browse Source
Merge pull request #6423 from abpframework/liangshiwei/patch-1
Set TaskCreationOptions.LongRunning for Kafka consumers
pull/6439/head
maliming
6 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
2 additions and
2 deletions
-
framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
|
|
|
@ -118,10 +118,10 @@ namespace Volo.Abp.Kafka |
|
|
|
catch (ConsumeException ex) |
|
|
|
{ |
|
|
|
Logger.LogException(ex, LogLevel.Warning); |
|
|
|
AsyncHelper.RunSync(() => ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning)); |
|
|
|
await ExceptionNotifier.NotifyAsync(ex, logLevel: LogLevel.Warning); |
|
|
|
} |
|
|
|
} |
|
|
|
}); |
|
|
|
}, TaskCreationOptions.LongRunning); |
|
|
|
} |
|
|
|
|
|
|
|
protected virtual async Task HandleIncomingMessage(ConsumeResult<string, byte[]> consumeResult) |
|
|
|
|