Skip to content

Commit a080faa

Browse files
Expose start message id inclusive configuration in C API (#27)
1 parent 4451cbd commit a080faa

File tree

3 files changed

+19
-0
lines changed

3 files changed

+19
-0
lines changed

include/pulsar/c/consumer_configuration.h

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -297,6 +297,12 @@ PULSAR_PUBLIC void pulsar_consumer_configuration_set_auto_ack_oldest_chunked_mes
297297
PULSAR_PUBLIC int pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_full(
298298
pulsar_consumer_configuration_t *consumer_configuration);
299299

300+
PULSAR_PUBLIC void pulsar_consumer_configuration_set_start_message_id_inclusive(
301+
pulsar_consumer_configuration_t *consumer_configuration, int start_message_id_inclusive);
302+
303+
PULSAR_PUBLIC int pulsar_consumer_configuration_is_start_message_id_inclusive(
304+
pulsar_consumer_configuration_t *consumer_configuration);
305+
300306
// const CryptoKeyReaderPtr getCryptoKeyReader()
301307
//
302308
// const;

lib/c/c_ConsumerConfiguration.cc

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -217,3 +217,13 @@ int pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_fu
217217
pulsar_consumer_configuration_t *consumer_configuration) {
218218
return consumer_configuration->consumerConfiguration.isAutoAckOldestChunkedMessageOnQueueFull();
219219
}
220+
221+
void pulsar_consumer_configuration_set_start_message_id_inclusive(
222+
pulsar_consumer_configuration_t *consumer_configuration, int start_message_id_inclusive) {
223+
consumer_configuration->consumerConfiguration.setStartMessageIdInclusive(start_message_id_inclusive);
224+
}
225+
226+
int pulsar_consumer_configuration_is_start_message_id_inclusive(
227+
pulsar_consumer_configuration_t *consumer_configuration) {
228+
return consumer_configuration->consumerConfiguration.isStartMessageIdInclusive();
229+
}

tests/c/c_ConsumerConfigurationTest.cc

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,4 +31,7 @@ TEST(C_ConsumerConfigurationTest, testCApiConfig) {
3131
pulsar_consumer_configuration_set_auto_ack_oldest_chunked_message_on_queue_full(consumer_conf, 1);
3232
ASSERT_EQ(pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_full(consumer_conf),
3333
1);
34+
35+
pulsar_consumer_configuration_set_start_message_id_inclusive(consumer_conf, 1);
36+
ASSERT_EQ(pulsar_consumer_configuration_is_start_message_id_inclusive(consumer_conf), 1);
3437
}

0 commit comments

Comments
 (0)