Browse Source
Merge pull request #10213 from abpframework/liangshiwei/patch-1
Update IKafkaMessageConsumerFactory
pull/10228/head
maliming
5 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with
0 additions and
4 deletions
-
framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/IKafkaMessageConsumerFactory.cs
-
framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumerFactory.cs
|
|
|
@ -8,13 +8,11 @@ |
|
|
|
/// not disposed until end of the application.
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="topicName"></param>
|
|
|
|
/// <param name="deadLetterTopicName"></param>
|
|
|
|
/// <param name="groupId"></param>
|
|
|
|
/// <param name="connectionName"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
IKafkaMessageConsumer Create( |
|
|
|
string topicName, |
|
|
|
string deadLetterTopicName, |
|
|
|
string groupId, |
|
|
|
string connectionName = null); |
|
|
|
} |
|
|
|
|
|
|
|
@ -1,5 +1,4 @@ |
|
|
|
using System; |
|
|
|
using System.Threading.Tasks; |
|
|
|
using Microsoft.Extensions.DependencyInjection; |
|
|
|
using Volo.Abp.DependencyInjection; |
|
|
|
|
|
|
|
@ -16,7 +15,6 @@ namespace Volo.Abp.Kafka |
|
|
|
|
|
|
|
public IKafkaMessageConsumer Create( |
|
|
|
string topicName, |
|
|
|
string deadLetterTopicName, |
|
|
|
string groupId, |
|
|
|
string connectionName = null) |
|
|
|
{ |
|
|
|
|