=)org/idempiere/hazelcast/service/TopicImpljava/lang/Object org/idempiere/distributed/ITopictopicLcom/hazelcast/topic/ITopic; Signature!Lcom/hazelcast/topic/ITopic;adaptersLjava/util/List;^Ljava/util/List.TopicSubscriberAdapter;>;registrationMapLjava/util/Map;oLjava/util/Map.TopicSubscriberAdapter;Ljava/lang/String;>;(Lcom/hazelcast/topic/ITopic;)V$(Lcom/hazelcast/topic/ITopic;)VCode  ()V  java/util/ArrayList    java/util/HashMap  # LineNumberTableLocalVariableTablethis+Lorg/idempiere/hazelcast/service/TopicImpl;LocalVariableTypeTable0Lorg/idempiere/hazelcast/service/TopicImpl;getName()Ljava/lang/String; -/.com/hazelcast/topic/ITopic *+ subscribe/(Lorg/idempiere/distributed/ITopicSubscriber;)V4(Lorg/idempiere/distributed/ITopicSubscriber;)V4@org/idempiere/hazelcast/service/TopicImpl$TopicSubscriberAdapter 36 7Z(Lorg/idempiere/hazelcast/service/TopicImpl;Lorg/idempiere/distributed/ITopicSubscriber;)V -9 :;addMessageListener7(Lcom/hazelcast/topic/MessageListener;)Ljava/util/UUID; =?>java/util/UUID @+toString BDCjava/util/List EFadd(Ljava/lang/Object;)Z HJI java/util/Map KLput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; subscriber,Lorg/idempiere/distributed/ITopicSubscriber;adapterBLorg/idempiere/hazelcast/service/TopicImpl$TopicSubscriberAdapter;registrationIdLjava/lang/String;1Lorg/idempiere/distributed/ITopicSubscriber;LLorg/idempiere/hazelcast/service/TopicImpl.TopicSubscriberAdapter; unsubscribe BW XYiterator()Ljava/util/Iterator; []\java/util/Iterator ^_next()Ljava/lang/Object; 3a MN Hc deget&(Ljava/lang/Object;)Ljava/lang/Object;gjava/lang/String =i jk fromString$(Ljava/lang/String;)Ljava/util/UUID; -m noremoveMessageListener(Ljava/util/UUID;)Z Hq reremove [t uvhasNext()Z Bx rFfound StackMapTable|*org/idempiere/distributed/ITopicSubscriberpublish(Ljava/lang/Object;)V(TE;)V - }~messageLjava/lang/Object;TE; SourceFileTopicImpl.javaOLjava/lang/Object;Lorg/idempiere/distributed/ITopic; InnerClassesTopicSubscriberAdapter NestMembers!        **+*Y*Y!"$*+ ,-.% &' ( &)  *+F *,$2%  &'(  &)01 203Y*+5M*,8