Skip to content

Commit 0322fb4

Browse files
committed
fix incompatibility issues
1 parent 1296e38 commit 0322fb4

File tree

2 files changed

+1
-8
lines changed

2 files changed

+1
-8
lines changed

pulsar/__init__.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -709,8 +709,7 @@ def __init__(self, service_url,
709709
Set the interval between each stats information update. Stats are printed and/or
710710
passed to the statistics listener at this interval. Set to 0 to disable stats collection.
711711
use_tls: bool, default=False
712-
Configure whether to use TLS encryption on the connection. This setting is deprecated.
713-
TLS will be automatically enabled if the ``serviceUrl`` is set to ``pulsar+ssl://`` or ``https://``
712+
it's a deprecated config that never works, whether TLS is enabled is determined by ``service_url``.
714713
tls_trust_certs_file_path: str, optional
715714
Set the path to the trusted TLS certificate file. If empty defaults to certifi.
716715
tls_allow_insecure_connection: bool, default=False
@@ -782,8 +781,6 @@ def __init__(self, service_url,
782781

783782
if listener_name:
784783
conf.listener_name(listener_name)
785-
if use_tls or service_url.startswith('pulsar+ssl://') or service_url.startswith('https://'):
786-
conf.use_tls(True)
787784
if tls_trust_certs_file_path:
788785
conf.tls_trust_certs_file_path(tls_trust_certs_file_path)
789786
else:

src/config.cc

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -174,10 +174,6 @@ void export_config(py::module_& m) {
174174
.def("stats_interval_in_seconds", &ClientConfiguration::getStatsIntervalInSeconds)
175175
.def("stats_interval_in_seconds", &ClientConfiguration::setStatsIntervalInSeconds,
176176
return_value_policy::reference)
177-
.def("use_tls", &ClientConfiguration::isUseTls)
178-
.def("use_tls", &ClientConfiguration::setUseTls, return_value_policy::reference)
179-
.def("tls_trust_certs_file_path", &ClientConfiguration::getTlsTrustCertsFilePath,
180-
return_value_policy::copy)
181177
.def("tls_trust_certs_file_path", &ClientConfiguration::setTlsTrustCertsFilePath,
182178
return_value_policy::reference)
183179
.def("tls_private_key_file_path", &ClientConfiguration::getTlsPrivateKeyFilePath,

0 commit comments

Comments
 (0)