You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/09/02 03:11:26 UTC

[GitHub] [pulsar] Demogorgon314 commented on a diff in pull request #17332: [feature][cpp] Expose Chunking configuration C API

Demogorgon314 commented on code in PR #17332:
URL: https://github.com/apache/pulsar/pull/17332#discussion_r961250510


##########
pulsar-client-cpp/lib/c/c_ConsumerConfiguration.cc:
##########
@@ -195,3 +195,25 @@ int pulsar_consumer_configuration_get_priority_level(
     pulsar_consumer_configuration_t *consumer_configuration) {
     return consumer_configuration->consumerConfiguration.getPriorityLevel();
 }
+
+void pulsar_consumer_configuration_set_max_pending_chunked_message(
+    pulsar_consumer_configuration_t *consumer_configuration, int max_pending_chunked_message) {
+    consumer_configuration->consumerConfiguration.setMaxPendingChunkedMessage(max_pending_chunked_message);
+}
+
+int pulsar_consumer_configuration_get_max_pending_chunked_message(
+    pulsar_consumer_configuration_t *consumer_configuration) {
+    return consumer_configuration->consumerConfiguration.getMaxPendingChunkedMessage();
+}
+
+void pulsar_consumer_configuration_set_auto_ack_oldest_chunked_message_on_queue_full(
+    pulsar_consumer_configuration_t *consumer_configuration,
+    int auto_ack_oldest_chunked_message_on_queue_full) {
+    consumer_configuration->consumerConfiguration.setAutoAckOldestChunkedMessageOnQueueFull(
+        auto_ack_oldest_chunked_message_on_queue_full);
+}
+
+int pulsar_consumer_configuration_get_auto_ack_oldest_chunked_message_on_queue_full(

Review Comment:
   Should be name as `pulsar_consumer_configuration_is_auto_ack_oldest_chunked_message_on_queue_full ` ?



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org