Skip to content

fix:优化pulsar组件部分参数项 #49

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 2 commits into
base: dev_6.0
Choose a base branch
from
Open

fix:优化pulsar组件部分参数项 #49

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
61bb7a8
fix:优化pulsar组件部分参数项
fanweix Jul 24, 2023
7ca12f2
Merge branch 'dev_6.0' of https://github.com/fanweix/NetPro into dev_6.0
fanweix Jul 24, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 18 additions & 10 deletions src/Library/NetPro.Pulsar/IPulsarQueneService.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumePatternAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumePatternAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);

/// <summary>
/// 批量消息订阅(正则topic)
Expand All @@ -38,7 +38,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumePatternBatchAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumePatternBatchAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);

/// <summary>
/// 消息订阅(完整topic)
Expand All @@ -53,7 +53,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumeAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumeAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);


/// <summary>
Expand All @@ -69,7 +69,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumeBatchAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumeBatchAsync(string tenantId, string projectId, string topic, string subscription, Func<string, string, string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);


/// <summary>
Expand All @@ -83,7 +83,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumePatternAsync(string topic, string subscription, Func<string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumePatternAsync(string topic, string subscription, Func<string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);

/// <summary>
/// 批量消息订阅(正则topic)
Expand All @@ -96,7 +96,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumePatternBatchAsync(string topic, string subscription, Func<string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumePatternBatchAsync(string topic, string subscription, Func<string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);

/// <summary>
/// 消息订阅(完整topic)
Expand All @@ -109,7 +109,7 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumeAsync(string topic, string subscriptiont, Func<string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumeAsync(string topic, string subscriptiont, Func<string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);


/// <summary>
Expand All @@ -123,17 +123,25 @@ public interface IPulsarQueneService
/// <param name="state">CancellationToken</param>
/// <returns></returns>
/// <exception cref="ArgumentNullException"></exception>
Task ConsumeBatchAsync(string topic, string subscription, Func<string, byte[], Task> func, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest, CancellationTokenSource state = default);
Task ConsumeBatchAsync(string topic, string subscription, Func<string, byte[], Task> func, CancellationToken state, SubscriptionType subscriptionType = SubscriptionType.Shared, SubscriptionInitialPosition initialPosition = SubscriptionInitialPosition.Latest);

/// <summary>
/// 发布消息
/// </summary>
/// <typeparam name="T">消息类型</typeparam>
/// <param name="topic">主题</param>
/// <param name="data">消息实例</param>
/// <returns></returns>
Task ProduceMessagesAsync<T>(string topic, T? data);

/// <summary>
/// 发布消息
/// </summary>
/// <typeparam name="T">消息类型</typeparam>
/// <param name="topic">主题</param>
/// <param name="data">消息实例</param>
/// <param name="state">CancellationToken</param>
/// <returns></returns>
Task ProduceMessagesAsync<T>(string topic, T? data, CancellationToken state = default);
Task ProduceMessagesServiceAsync<T>(string topic, T? data, int producerNum = 1);


}
Expand Down
Loading