File tree Expand file tree Collapse file tree 2 files changed +8
-0
lines changed
tests/integration/backward_compatible/ssl_tests Expand file tree Collapse file tree 2 files changed +8
-0
lines changed Original file line number Diff line number Diff line change 4949 Ringbuffer ,
5050 Set ,
5151 Topic ,
52+ _proxy_init ,
5253)
5354from hazelcast .proxy .base import Proxy
5455from hazelcast .proxy .map import Map
6768
6869_logger = logging .getLogger (__name__ )
6970
71+ _SUPPORTED_DDS_NAMES = set (_proxy_init .keys ())
72+
7073
7174class HazelcastClient :
7275 """Hazelcast client instance to access and manipulate distributed data
@@ -495,8 +498,13 @@ def get_distributed_objects(self) -> typing.List[Proxy]:
495498 }
496499
497500 response = client_get_distributed_objects_codec .decode_response (invocation .future .result ())
501+
498502 for dist_obj_info in response :
499503 local_distributed_object_infos .discard (dist_obj_info )
504+
505+ # skip unsupported proxies, e.g., hz:impl:cacheService
506+ if dist_obj_info .service_name not in _SUPPORTED_DDS_NAMES :
507+ continue
500508 self ._proxy_manager .get_or_create (
501509 dist_obj_info .service_name , dist_obj_info .name , create_on_remote = False
502510 )
You can’t perform that action at this time.
0 commit comments