BewareMyPower commented on code in PR #17332:
URL: https://github.com/apache/pulsar/pull/17332#discussion_r961771012
##########
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:
+1
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
