call correct function to set subscription role prefix (#416)

candu · shibd · commit 295dfecdeace · 2025-05-26T18:02:28.000+08:00
(cherry picked from commit 8b2cfd3)
diff --git a/src/ReaderConfig.cc b/src/ReaderConfig.cc
@@ -72,7 +72,8 @@ ReaderConfig::ReaderConfig(const Napi::Object &readerConfig, pulsar_reader_liste
     std::string subscriptionRolePrefix =
         readerConfig.Get(CFG_SUBSCRIPTION_ROLE_PREFIX).ToString().Utf8Value();
     if (!subscriptionRolePrefix.empty())
-      pulsar_reader_configuration_set_reader_name(this->cReaderConfig.get(), subscriptionRolePrefix.c_str());
+      pulsar_reader_configuration_set_subscription_role_prefix(this->cReaderConfig.get(),
+                                                               subscriptionRolePrefix.c_str());
   }
 
   if (readerConfig.Has(CFG_READ_COMPACTED) && readerConfig.Get(CFG_READ_COMPACTED).IsBoolean()) {

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,8 @@ ReaderConfig::ReaderConfig(const Napi::Object &readerConfig, pulsar_reader_liste`
`72`	`72`	`std::string subscriptionRolePrefix =`
`73`	`73`	`readerConfig.Get(CFG_SUBSCRIPTION_ROLE_PREFIX).ToString().Utf8Value();`
`74`	`74`	`if (!subscriptionRolePrefix.empty())`
`75`		`- pulsar_reader_configuration_set_reader_name(this->cReaderConfig.get(), subscriptionRolePrefix.c_str());`
	`75`	`+ pulsar_reader_configuration_set_subscription_role_prefix(this->cReaderConfig.get(),`
	`76`	`+ subscriptionRolePrefix.c_str());`
`76`	`77`	`}`
`77`	`78`
`78`	`79`	`if (readerConfig.Has(CFG_READ_COMPACTED) && readerConfig.Get(CFG_READ_COMPACTED).IsBoolean()) {`