You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ch...@apache.org on 2021/11/04 11:18:54 UTC
[pulsar] 06/14: [CAPI] Support setting priority for consumers
(#12526)
This is an automated email from the ASF dual-hosted git repository.
chenhang pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 40fd57496e278e491a8fe6272a00900da51d7bc8
Author: Yuto Furuta <mz...@gmail.com>
AuthorDate: Tue Nov 2 21:05:31 2021 +0900
[CAPI] Support setting priority for consumers (#12526)
### Motivation
We would like to make it possible for C API based client library to set the priority level for consumers.
### Modifications
Add methods to set/get priority level for consumers.
Co-authored-by: k2la <yf...@yahoo-corp.jp>
(cherry picked from commit a75a9746a12a6461c87518434f0f550563718e9d)
---
pulsar-client-cpp/include/pulsar/c/consumer_configuration.h | 6 ++++++
pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc | 10 ++++++++++
2 files changed, 16 insertions(+)
diff --git a/pulsar-client-cpp/include/pulsar/c/consumer_configuration.h b/pulsar-client-cpp/include/pulsar/c/consumer_configuration.h
index efe353a..a11e11e 100644
--- a/pulsar-client-cpp/include/pulsar/c/consumer_configuration.h
+++ b/pulsar-client-cpp/include/pulsar/c/consumer_configuration.h
@@ -275,6 +275,12 @@ PULSAR_PUBLIC void pulsar_consumer_set_subscription_initial_position(
PULSAR_PUBLIC void pulsar_consumer_configuration_set_property(pulsar_consumer_configuration_t *conf,
const char *name, const char *value);
+PULSAR_PUBLIC void pulsar_consumer_configuration_set_priority_level(
+ pulsar_consumer_configuration_t *consumer_configuration, int priority_level);
+
+PULSAR_PUBLIC int pulsar_consumer_configuration_get_priority_level(
+ pulsar_consumer_configuration_t *consumer_configuration);
+
// const CryptoKeyReaderPtr getCryptoKeyReader()
//
// const;
diff --git a/pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc b/pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc
index 90c60df..aaec12c 100644
--- a/pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc
+++ b/pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc
@@ -185,3 +185,13 @@ int pulsar_consumer_get_subscription_initial_position(
pulsar_consumer_configuration_t *consumer_configuration) {
return consumer_configuration->consumerConfiguration.getSubscriptionInitialPosition();
}
+
+void pulsar_consumer_configuration_set_priority_level(pulsar_consumer_configuration_t *consumer_configuration,
+ int priority_level) {
+ consumer_configuration->consumerConfiguration.setPriorityLevel(priority_level);
+}
+
+int pulsar_consumer_configuration_get_priority_level(
+ pulsar_consumer_configuration_t *consumer_configuration) {
+ return consumer_configuration->consumerConfiguration.getPriorityLevel();
+}