Skip to content

Commit 7087a8e

Browse files
authored
Expose Get/Set Listener Name in C API (apache#370)
1 parent 27cba3e commit 7087a8e

File tree

3 files changed

+17
-0
lines changed

3 files changed

+17
-0
lines changed

include/pulsar/c/client_configuration.h

+5
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,11 @@ PULSAR_PUBLIC int pulsar_client_configuration_is_validate_hostname(pulsar_client
187187
PULSAR_PUBLIC void pulsar_client_configuration_set_validate_hostname(pulsar_client_configuration_t *conf,
188188
int validateHostName);
189189

190+
PULSAR_PUBLIC void pulsar_client_configuration_set_listener_name(pulsar_client_configuration_t *conf,
191+
const char *listenerName);
192+
193+
PULSAR_PUBLIC const char *pulsar_client_configuration_get_listener_name(pulsar_client_configuration_t *conf);
194+
190195
/*
191196
* Get the stats interval set in the client.
192197
*/

lib/c/c_ClientConfiguration.cc

+9
Original file line numberDiff line numberDiff line change
@@ -189,3 +189,12 @@ void pulsar_client_configuration_set_memory_limit(pulsar_client_configuration_t
189189
unsigned long long pulsar_client_configuration_get_memory_limit(pulsar_client_configuration_t *conf) {
190190
return conf->conf.getMemoryLimit();
191191
}
192+
193+
void pulsar_client_configuration_set_listener_name(pulsar_client_configuration_t *conf,
194+
const char *listenerName) {
195+
conf->conf.setListenerName(listenerName);
196+
}
197+
198+
const char *pulsar_client_configuration_get_listener_name(pulsar_client_configuration_t *conf) {
199+
return conf->conf.getListenerName().c_str();
200+
}

tests/c/c_ClientConfigurationTest.cc

+3
Original file line numberDiff line numberDiff line change
@@ -28,4 +28,7 @@ TEST(C_ClientConfigurationTest, testCApiConfig) {
2828

2929
ASSERT_STREQ(pulsar_client_configuration_get_tls_private_key_file_path(conf), "private.key");
3030
ASSERT_STREQ(pulsar_client_configuration_get_tls_certificate_file_path(conf), "certificate.pem");
31+
32+
pulsar_client_configuration_set_listener_name(conf, "listenerName");
33+
ASSERT_STREQ(pulsar_client_configuration_get_listener_name(conf), "listenerName");
3134
}

0 commit comments

Comments
 (0)