4,com/hazelcast/client/impl/ClientEndpointImpljava/lang/Object(com/hazelcast/client/impl/ClientEndpointClientEndpointImpl.java.com/hazelcast/client/impl/ClientEndpointImpl$2.com/hazelcast/client/impl/ClientEndpointImpl$1  clientEngine(Lcom/hazelcast/client/impl/ClientEngine;loggerLcom/hazelcast/logging/ILogger; nodeEngine'Lcom/hazelcast/spi/impl/NodeEngineImpl; connectionLcom/hazelcast/nio/Connection;transactionContextMap$Ljava/util/concurrent/ConcurrentMap;fLjava/util/concurrent/ConcurrentMap;removeListenerActionsWLjava/util/concurrent/ConcurrentMap; socketAddressLjava/net/SocketAddress; creationTimeJ loginContext(Ljavax/security/auth/login/LoginContext; principal2Lcom/hazelcast/client/impl/client/ClientPrincipal;ownerConnectionZ credentials$Lcom/hazelcast/security/Credentials; authenticated clientVersionIclientVersionStringLjava/lang/String;authenticationCorrelationIdstats clientNamelabelsLjava/util/Set;#Ljava/util/Set; destroyedp(Lcom/hazelcast/client/impl/ClientEngine;Lcom/hazelcast/spi/impl/NodeEngineImpl;Lcom/hazelcast/nio/Connection;)V()V 13 4&java/util/concurrent/ConcurrentHashMap6 74  9  ; =getClass()Ljava/lang/Class; ?@ A&com/hazelcast/client/impl/ClientEngineC getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; EF DG  I  K  M%com/hazelcast/nio/tcp/TcpIpConnectionOgetRemoteSocketAddress()Ljava/net/InetSocketAddress; QR PS  U%com/hazelcast/spi/impl/NodeEngineImplWcom/hazelcast/nio/ConnectionY &' [Unknown] () _java/lang/SystemacurrentTimeMillis()J cd be  gtcpIpConnection'Lcom/hazelcast/nio/tcp/TcpIpConnection;this.Lcom/hazelcast/client/impl/ClientEndpointImpl; getConnection ()Lcom/hazelcast/nio/Connection;getUuid()Ljava/lang/String;  q0com/hazelcast/client/impl/client/ClientPrincipals op tujava/lang/StringwisAlive()Z yz Z{setLoginContext+(Ljavax/security/auth/login/LoginContext;)V   getSubject()Ljavax/security/auth/Subject;&javax/security/auth/login/LoginContext javax/security/auth/SubjectisOwnerConnection !" (Lcom/hazelcast/client/impl/client/ClientPrincipal;Lcom/hazelcast/security/Credentials;ZLjava/lang/String;JLjava/lang/String;Ljava/util/Set;)V(Lcom/hazelcast/client/impl/client/ClientPrincipal;Lcom/hazelcast/security/Credentials;ZLjava/lang/String;JLjava/lang/String;Ljava/util/Set;)V #$  %"  * setClientVersion(Ljava/lang/String;)V  ,)  -. firstConnectionauthCorrelationId5(Lcom/hazelcast/client/impl/client/ClientPrincipal;)VisAuthenticatedgetClientVersion()I com/hazelcast/instance/BuildInfocalculateVersion(Ljava/lang/String;)I versionsetClientStatistics +) getClientStatisticsgetSocketAddressjava/net/InetSocketAddress getClientType!()Lcom/hazelcast/core/ClientType;+$SwitchMap$com$hazelcast$nio$ConnectionType[I getType$()Lcom/hazelcast/nio/ConnectionType; Z com/hazelcast/nio/ConnectionTypeordinal com/hazelcast/core/ClientTypeJAVALcom/hazelcast/core/ClientType; CSHARP CPP PYTHON RUBY NODEJS GO OTHER "java/lang/IllegalArgumentExceptionjava/lang/StringBuilder 4Invalid connection type: append-(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString p 1 typegetName getLabels()Ljava/util/Set;%()Ljava/util/Set;getTransactionContextB(Ljava/lang/String;)Lcom/hazelcast/transaction/TransactionContext;"java/util/concurrent/ConcurrentMapget&(Ljava/lang/Object;)Ljava/lang/Object; ,com/hazelcast/transaction/TransactionContext.com/hazelcast/transaction/TransactionException'No transaction context found for txnId: txnIdtransactionContext.Lcom/hazelcast/transaction/TransactionContext;getCredentials&()Lcom/hazelcast/security/Credentials;setTransactionContext1(Lcom/hazelcast/transaction/TransactionContext;)VgetTxnId p  put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;    0" $removedAndRollbackTransactionContext  removeTransactionContextremove  addListenerDestroyAction9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)VgetEventService"()Lcom/hazelcast/spi/EventService;  D(Lcom/hazelcast/client/impl/ClientEndpointImpl;Lcom/hazelcast/spi/EventService;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V 1 addDestroyAction4(Ljava/lang/String;Ljava/util/concurrent/Callable;)V !" #servicetopicid eventService Lcom/hazelcast/spi/EventService;I(Ljava/lang/String;Ljava/util/concurrent/Callable;)VremoveAndCallRemoveAction + ,registrationId removeAction4Ljava/util/concurrent/Callable;Ljava/util/concurrent/Callable;removeDestroyAction(Ljava/lang/String;)ZclearAllListenerskeySet 5 6 java/util/Set8iterator()Ljava/util/Iterator; :; 9<java/util/Iterator>hasNext @z ?Anext()Ljava/lang/Object; CD ?Edestroy(javax/security/auth/login/LoginExceptionH uonClientDisconnected K XL 43 Nlogout P3 Qjava/lang/ThrowableSlcjava/lang/ExceptionVjava/util/concurrent/CallableXcall ZD Y['Exception during remove listener action]com/hazelcast/logging/ILogger_warning*(Ljava/lang/String;Ljava/lang/Throwable;)V ab `ceLjava/lang/Exception;uuidcallable6com/hazelcast/core/HazelcastInstanceNotActiveExceptioni:com/hazelcast/transaction/impl/xa/XATransactionContextImplkrollbackTransaction m3 nfinest(Ljava/lang/Throwable;)V pq `r aq `t8Lcom/hazelcast/core/HazelcastInstanceNotActiveException;contextClientEndpoint{connection=x , principal='z, ownerConnection=|(Z)Ljava/lang/StringBuilder; ~ , authenticated=, clientVersion=, creationTime=(J)Ljava/lang/StringBuilder;  , latest statistics=(C)Ljava/lang/StringBuilder;  getAuthenticationCorrelationId()Ljava/net/SocketAddress; R  SignatureCode StackMapTableLineNumberTableLocalVariableTableLocalVariableTypeTable Exceptions InnerClasses SourceFile1  !"#$B%"&'()*B+),)-./B0" 12h*5*7Y8:*7Y8<*+>*+*BHJ*,L*-N-P-P:*TV*V*\*^`*fhPDXZBG46HI-J2K7L>MDNMOPPURZS`TgU4D ijhklh hhmn/*NY klopJ*r *rv@x^ klyz4 *N|c  kl}~>*+ hiklJ* *@m klz/*q kl% -*+r**,*****& wx yz{| }&~,R-kl- -#$-"-&)--,)--. --/%G *+r*  kl  z/* kl/*\ klJ*+`*+\ kl)>*+ kl+)p/* klR2*V kl*N.h07>ELSZaLWLPLILBL;L4L-L&YY*N+ @"N@DGKNRUY\`cgjnquxf DKRY`gnuklp/* kl/* kl/*:+M,YY+,-- /kl/)!/* kll#*:+ +W* *+ ""#kl#D *:+W   kl )x *>:*- Y*+,- $ 4kl%)&)') ()!"~*<+,W**+-  kl.)/1 /0*23R*<+@kl')43|+*<7=L+B+FxM*,- ?"' * ".)+klG3\**L*JM*O*:7=L+B+FxM*,*L++R* N*->KS#? GT: 6;>CGKPSY[ 6)CU\klI++*<+YM,,\WN*J^-dWxYW !"$'%&*)* ef+kl+g)h1=*:+M,-,l,oN*J-sN*J-u #j 1WHjMW 2 ,-./2 7#3$4.71526<94$ ev2 ef=kl=)/wpkYy*N{*r}***`*h*}> kkld/*J klA/*. kl