[pulsar-client-cpp] branch main updated: Expose start message id inclusive configuration in C API (#27)

[mmerli]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git


The following commit(s) were added to refs/heads/main by this push:
     new a080faa  Expose start message id inclusive configuration in C API (#27)
a080faa is described below

commit a080faa32744901978d841dee8bee7098c0d7da4
Author: Kai Wang <kw...@apache.org>
AuthorDate: Mon Oct 10 01:02:27 2022 +0800

    Expose start message id inclusive configuration in C API (#27)
---
 include/pulsar/c/consumer_configuration.h |  6 ++++++
 lib/c/c_ConsumerConfiguration.cc          | 10 ++++++++++
 tests/c/c_ConsumerConfigurationTest.cc    |  3 +++
 3 files changed, 19 insertions(+)

diff --git a/include/pulsar/c/consumer_configuration.h 
b/include/pulsar/c/consumer_configuration.h
index fc3ccec..128fa24 100644
--- a/include/pulsar/c/consumer_configuration.h
+++ b/include/pulsar/c/consumer_configuration.h
@@ -297,6 +297,12 @@ PULSAR_PUBLIC void 
pulsar_consumer_configuration_set_auto_ack_oldest_chunked_mes
 PULSAR_PUBLIC int 
pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_full(
     pulsar_consumer_configuration_t *consumer_configuration);
 
+PULSAR_PUBLIC void 
pulsar_consumer_configuration_set_start_message_id_inclusive(
+    pulsar_consumer_configuration_t *consumer_configuration, int 
start_message_id_inclusive);
+
+PULSAR_PUBLIC int pulsar_consumer_configuration_is_start_message_id_inclusive(
+    pulsar_consumer_configuration_t *consumer_configuration);
+
 // const CryptoKeyReaderPtr getCryptoKeyReader()
 //
 // const;
diff --git a/lib/c/c_ConsumerConfiguration.cc b/lib/c/c_ConsumerConfiguration.cc
index 8e1d1ae..6b0d27b 100644
--- a/lib/c/c_ConsumerConfiguration.cc
+++ b/lib/c/c_ConsumerConfiguration.cc
@@ -217,3 +217,13 @@ int 
pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_fu
     pulsar_consumer_configuration_t *consumer_configuration) {
     return 
consumer_configuration->consumerConfiguration.isAutoAckOldestChunkedMessageOnQueueFull();
 }
+
+void pulsar_consumer_configuration_set_start_message_id_inclusive(
+    pulsar_consumer_configuration_t *consumer_configuration, int 
start_message_id_inclusive) {
+    
consumer_configuration->consumerConfiguration.setStartMessageIdInclusive(start_message_id_inclusive);
+}
+
+int pulsar_consumer_configuration_is_start_message_id_inclusive(
+    pulsar_consumer_configuration_t *consumer_configuration) {
+    return 
consumer_configuration->consumerConfiguration.isStartMessageIdInclusive();
+}
diff --git a/tests/c/c_ConsumerConfigurationTest.cc 
b/tests/c/c_ConsumerConfigurationTest.cc
index f2bea95..c6afeef 100644
--- a/tests/c/c_ConsumerConfigurationTest.cc
+++ b/tests/c/c_ConsumerConfigurationTest.cc
@@ -31,4 +31,7 @@ TEST(C_ConsumerConfigurationTest, testCApiConfig) {
     
pulsar_consumer_configuration_set_auto_ack_oldest_chunked_message_on_queue_full(consumer_conf,
 1);
     
ASSERT_EQ(pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_full(consumer_conf),
               1);
+
+    
pulsar_consumer_configuration_set_start_message_id_inclusive(consumer_conf, 1);
+    
ASSERT_EQ(pulsar_consumer_configuration_is_start_message_id_inclusive(consumer_conf),
 1);
 }