╩■║╛4"io/moquette/broker/Session java/time/ClocksystemDefaultZone()Ljava/time/Clock; "io/moquette/broker/SessionRegistry(Lio/moquette/broker/subscriptions/ISubscriptionsDirectory;Lio/moquette/broker/ISessionsRepository;Lio/moquette/broker/IQueueRepository;Lio/moquette/broker/Authorizator;Ljava/util/concurrent/ScheduledExecutorService;Ljava/time/Clock;ILio/moquette/broker/SessionEventLoopGroup;)V java/lang/Object()V&java/util/concurrent/ConcurrentHashMap pool$Ljava/util/concurrent/ConcurrentMap;java/util/concurrent/DelayQueue !"removableSessions!Ljava/util/concurrent/DelayQueue; $%&subscriptionsDirectory:Lio/moquette/broker/subscriptions/ISubscriptionsDirectory; ()*sessionsRepository(Lio/moquette/broker/ISessionsRepository; ,-.queueRepository%Lio/moquette/broker/IQueueRepository; 012authorizator!Lio/moquette/broker/Authorizator;456run:(Lio/moquette/broker/SessionRegistry;)Ljava/lang/Runnable; 89:%EXPIRED_SESSION_CLEANER_TASK_INTERVALLjava/time/Duration; <=>?@java/time/Duration getSeconds()J BCDEFjava/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit;HIJKL-java/util/concurrent/ScheduledExecutorServicescheduleWithFixedDelay](Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture; NOPscheduledExpiredSessions&Ljava/util/concurrent/ScheduledFuture; RSTclockLjava/time/Clock; VWXglobalExpirySecondsI Z[\ loopsGroup*Lio/moquette/broker/SessionEventLoopGroup; ^_recreateSessionPoolajava/util/ArrayList ` defdrainTo(Ljava/util/Collection;)I hijLOGLorg/slf4j/Logger;l#Retrieved {} expired sessions or {} nopqrjava/lang/IntegervalueOf(I)Ljava/lang/Integer; tuvsize()Ixyz{|org/slf4j/Loggerdebug9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V~АБВjava/util/Listiterator()Ljava/util/Iterator;ДЕЖЗИjava/util/IteratorhasNext()ZДКЛМnext()Ljava/lang/Object;О2io/moquette/broker/ISessionsRepository$SessionData НРСТexpireAt()Ljava/util/Optional;ФХЦapply()Ljava/util/function/Function; ШЩЪЫЬjava/util/Optionalmap3(Ljava/util/function/Function;)Ljava/util/Optional;Ю UNDEFINED ШабвorElse&(Ljava/lang/Object;)Ljava/lang/Object;дjava/lang/Stringж"Removing session {}, expired on {} НийкclientId()Ljava/lang/String; мноremove(Ljava/lang/String;)V░▒▓│┤&io/moquette/broker/ISessionsRepositorydelete7(Lio/moquette/broker/ISessionsRepository$SessionData;)V Ш╢╖И isPresent╣java/lang/RuntimeException╗java/lang/StringBuilder ║╛HCan't track for expiration a session without expiry instant, client_id: ║└┴┬append-(Ljava/lang/String;)Ljava/lang/StringBuilder; ║─┼кtoString ╕╟о╔)start tracking the session {} for removalx╦{╠'(Ljava/lang/String;Ljava/lang/Object;)V ╬╧╨add!(Ljava/util/concurrent/Delayed;)Z ╥н╙(Ljava/lang/Object;)Z╒╓╫╪┘#io/moquette/broker/IQueueRepositorylistQueueNames()Ljava/util/Set;░█▄▌list()Ljava/util/Collection;▀рjava/util/Collection╒туф containsQueue(Ljava/lang/String;)Z╒цчшgetOrCreateQueue<(Ljava/lang/String;)Lio/moquette/broker/SessionMessageQueue;ъ╥ы java/util/Set эю`(Lio/moquette/broker/ISessionsRepository$SessionData;ZLio/moquette/broker/SessionMessageQueue;)VЁёЄєЇ"java/util/concurrent/ConcurrentMapput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; Ўў┤trackForRemovalOnExpirationъ∙·ИisEmpty№RRecreating sessions left {} unused queues. This is probably a bug. Session IDs: {}ъtъ toArray()[Ljava/lang/Object; ┼java/util/Arrays'([Ljava/lang/Object;)Ljava/lang/String;x |error retrieve0(Ljava/lang/String;)Lio/moquette/broker/Session; createNewSession`(Lio/netty/handler/codec/mqtt/MqttConnectMessage;Ljava/lang/String;)Lio/moquette/broker/Session;8io/moquette/broker/SessionRegistry$SessionCreationResult 3io/moquette/broker/SessionRegistry$CreationModeEnumCREATED_CLEAN_NEW5Lio/moquette/broker/SessionRegistry$CreationModeEnum; U(Lio/moquette/broker/Session;Lio/moquette/broker/SessionRegistry$CreationModeEnum;Z)VBAnother thread added a Session for our clientId {}, this is a bug!x ╠"(case 1, not existing session with CId {}x$%╠trace '()reopenExistingSessionм(Lio/netty/handler/codec/mqtt/MqttConnectMessage;Ljava/lang/String;Lio/moquette/broker/Session;Ljava/lang/String;)Lio/moquette/broker/SessionRegistry$SessionCreationResult; +,-./.io/netty/handler/codec/mqtt/MqttConnectMessagevariableHeader9()Lio/netty/handler/codec/mqtt/MqttConnectVariableHeader; 1234И5io/netty/handler/codec/mqtt/MqttConnectVariableHeaderisCleanSession 67Иdisconnected 9:closeImmediately <=>purgeSessionState(Lio/moquette/broker/Session;)V@0case 2, oldSession with same CId {} disconnected BCDEF(io/moquette/broker/Session$SessionStatusDISCONNECTED*Lio/moquette/broker/Session$SessionStatus; BHIF CONNECTING KLMassignStateW(Lio/moquette/broker/Session$SessionStatus;Lio/moquette/broker/Session$SessionStatus;)ZO,io/moquette/broker/SessionCorruptedExceptionQ4old session moved in connected state by other thread N╟ TUVcopySessionConfigO(Lio/netty/handler/codec/mqtt/MqttConnectMessage;Lio/moquette/broker/Session;)V XYZreactivateSubscriptions1(Lio/moquette/broker/Session;Ljava/lang/String;)V\0case 3, oldSession with same CId {} disconnected ^_REOPEN_EXISTING abcsessionLio/moquette/broker/Session; efggetSessionData6()Lio/moquette/broker/ISessionsRepository$SessionData; ij┤untrackFromRemovalOnExpiration lmngetSubscriptions()Ljava/util/List;p-io/moquette/broker/subscriptions/Subscription orstgetTopicFilter*()Lio/moquette/broker/subscriptions/Topic; vwкgetClientID yz{|}io/moquette/broker/AuthorizatorcanReadO(Lio/moquette/broker/subscriptions/Topic;Ljava/lang/String;Ljava/lang/String;)ZАБВГ8io/moquette/broker/subscriptions/ISubscriptionsDirectoryremoveSubscription=(Lio/moquette/broker/subscriptions/Topic;Ljava/lang/String;)VЕ io/moquette/broker/InMemoryQueue Д ИЙКЛМ'io/netty/handler/codec/mqtt/MqttVersion MQTT_3_1_1)Lio/netty/handler/codec/mqtt/MqttVersion; НОПP(Ljava/lang/String;Lio/netty/handler/codec/mqtt/MqttVersion;ILjava/time/Clock;)V 1СТИ isWillFlag ФХЦ createWillS(Lio/netty/handler/codec/mqtt/MqttConnectMessage;)Lio/moquette/broker/Session$Will; ШЩБ(Lio/moquette/broker/ISessionsRepository$SessionData;ZLio/moquette/broker/Session$Will;Lio/moquette/broker/SessionMessageQueue;)V ЫЬmarkConnecting░ЮЯ┤saveSession бвгupdate%(ZLio/moquette/broker/Session$Will;)V +ежзpayload2()Lio/netty/handler/codec/mqtt/MqttConnectPayload; йклмн.io/netty/handler/codec/mqtt/MqttConnectPayloadwillMessageInBytes()[B п░▒▓│io/netty/buffer/UnpooledcopiedBuffer([B)Lio/netty/buffer/ByteBuf; й╡╢к willTopic 1╕╣ИisWillRetain 1╗╝vwillQos ╛┐└q┴#io/netty/handler/codec/mqtt/MqttQoS((I)Lio/netty/handler/codec/mqtt/MqttQoS;├io/moquette/broker/Session$Will ┬┼╞T(Ljava/lang/String;Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/mqtt/MqttQoS;Z)VЁ╚╔вget ╦╠ disconnect ╬╧ИexpireImmediately Н╤╥gwithExpirationComputed╘"Remove session state for client {} B╓╫F DESTROYED┘#Session has already changed state: ║█┴▄-(Ljava/lang/Object;)Ljava/lang/StringBuilder; ▐▀>unsubscribeЁснвуClean up removed sessionхцчcall=(Lio/moquette/broker/Session;)Ljava/util/concurrent/Callable; щъыьэ(io/moquette/broker/SessionEventLoopGrouprouteCommandp(Ljava/lang/String;Ljava/lang/String;Ljava/util/concurrent/Callable;)Lio/moquette/broker/PostOffice$RouteResult;ЁяЁ▌values▀ЄєЇstream()Ljava/util/stream/Stream;Ўў°test ()Ljava/util/function/Predicate;·√№¤■java/util/stream/Streamfilter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;ХC(Lio/moquette/broker/SessionRegistry;)Ljava/util/function/Function;·Ы8(Ljava/util/function/Function;)Ljava/util/stream/Stream;ЎФ java/util/stream/CollectorstoList()Ljava/util/stream/Collector;·collect0(Ljava/util/stream/Collector;)Ljava/lang/Object;Disconnecting client: {})Client {} not found, nothing disconnected/Client {} successfully disconnected from broker Т remoteAddressХ1(Ljava/lang/String;)Ljava/util/function/Function; !"$java/util/concurrent/ScheduledFuturecancel(Z)Z$,Successfully cancelled expired sessions taskx&'оinfo)\Can't cancel the execution of expired sessions task, was already cancelled? {}, was done? {}+,ИisCancelled ./0q1java/lang/Boolean(Z)Ljava/lang/Boolean;34ИisDonex67|warn 9:&updateNotCleanSessionsWithProperExpire╒<=closeЎ Ф ЎФ CDEFвjava/util/ObjectsrequireNonNullHIJacceptG(Lio/moquette/broker/ISessionsRepository;)Ljava/util/function/Consumer;·LMNforEach (Ljava/util/function/Consumer;)V PQИisCleanS#io/moquette/broker/ClientDescriptor UVWXкjava/net/InetSocketAddress getHostString UZ[vgetPort R]^((Ljava/lang/String;Ljava/lang/String;I)V `acleanUp ;TLjava/util/concurrent/ConcurrentMap;WLjava/util/concurrent/DelayQueue;(Lio/moquette/broker/subscriptions/ISubscriptionsDirectory;Lio/moquette/broker/ISessionsRepository;Lio/moquette/broker/IQueueRepository;Lio/moquette/broker/Authorizator;Ljava/util/concurrent/ScheduledExecutorService;Lio/moquette/broker/SessionEventLoopGroup;)VCodeLineNumberTableLocalVariableTablethis$Lio/moquette/broker/SessionRegistry; scheduler/Ljava/util/concurrent/ScheduledExecutorService;checkExpiredSessions expiredAtLjava/lang/String;expiredSession4Lio/moquette/broker/ISessionsRepository$SessionData;expiredSessionsLjava/util/List;drainedSessionsLocalVariableTypeTableFLjava/util/List; StackMapTablepersistentQueue(Lio/moquette/broker/SessionMessageQueue; rehydratedqueuesLjava/util/Set;^Lio/moquette/broker/SessionMessageQueue;#Ljava/util/Set;createOrReopenSessionР(Lio/netty/handler/codec/mqtt/MqttConnectMessage;Ljava/lang/String;Ljava/lang/String;)Lio/moquette/broker/SessionRegistry$SessionCreationResult; newSessionpreviouspostConnectAction:Lio/moquette/broker/SessionRegistry$SessionCreationResult;msg0Lio/netty/handler/codec/mqtt/MqttConnectMessage;username oldSessioncreationResult connectingZ newIsClean topicReadableexistingSub/Lio/moquette/broker/subscriptions/Subscription;queuewill!Lio/moquette/broker/Session$Will;cleanexpiryIntervalsessionDataв&io/moquette/broker/SessionMessageQueuewillPayloadLio/netty/buffer/ByteBuf;retainedqos%Lio/netty/handler/codec/mqtt/MqttQoS;clientIDconnectionClosedresultoldlistConnectedClients?()Ljava/util/Collection;dropSession(Ljava/lang/String;Z)ZremoveSessionStateclientcreateClientDescriptor2(Lio/moquette/broker/Session;)Ljava/util/Optional;sremoteAddressOptLjava/util/Optional;2Ljava/util/Optional;Y(Lio/moquette/broker/Session;)Ljava/util/Optional;/lambda$updateNotCleanSessionsWithProperExpire$37(Lio/moquette/broker/ISessionsRepository$SessionData;)Z/lambda$updateNotCleanSessionsWithProperExpire$2(Lio/moquette/broker/Session;)Zlambda$createClientDescriptor$1U(Ljava/lang/String;Ljava/net/InetSocketAddress;)Lio/moquette/broker/ClientDescriptor;rLjava/net/InetSocketAddress;lambda$remove$00(Lio/moquette/broker/Session;)Ljava/lang/String; Exceptions┼java/lang/Exception SourceFileSessionRegistry.javaBootstrapMethods╦ ╠═╬╧╨"java/lang/invoke/LambdaMetafactorymetafactory╠(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;╙ ╘xв╫ ╪─┘java/time/Instant█'(Ljava/time/Instant;)Ljava/lang/String;М▐ ▀┴┬к╙у фхИ connected╝ш щ▓││╡э(Ljava/util/Optional;)Zя ШЁ╔МЄ;(Ljava/util/Optional;)Lio/moquette/broker/ClientDescriptor;Ї ї╜╛ўC(Ljava/net/InetSocketAddress;)Lio/moquette/broker/ClientDescriptor;∙ ·╗╝d¤R(Lio/moquette/broker/Session;)Lio/moquette/broker/ISessionsRepository$SessionData; ╣║║╨j(Lio/moquette/broker/ISessionsRepository$SessionData;)Lio/moquette/broker/ISessionsRepository$SessionData;(Ljava/lang/Object;)V Э┤InnerClassesSessionDataSessionCreationResultCreationModeEnum SessionStatusWill)io/moquette/broker/PostOffice$RouteResultio/moquette/broker/PostOfficeRouteResult/io/moquette/broker/SessionRegistry$PubRelMarkerPubRelMarker3io/moquette/broker/SessionRegistry$PublishedMessagePublishedMessage2io/moquette/broker/SessionRegistry$EnqueuedMessageEnqueuedMessage%java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandlesLookup!OPlmWX[\9:ijln%&)*-.12!"loSTpq} *+,-╕ ╖ ▒r ХЦsHtu%&)*-.12vw[\q f*╖*╗Y╖╡*╗Y╖╡*+╡#*,╡'*-╡+*╡/**║3▓7╢;▓7╢;▓A╣G╡M*╡Q*╡U*╡Y*╖]▒r>ЮЖЛЯа$б)в/г;дGгOжUз[иaйeкs\ ftuf%&f)*f-.f12fvwfSTfWXf[\xq!Д╗`Y╖bL*┤+╢c=▓gk╕m*┤╢s╕m╣w+╣}N-╣ГЩM-╣Й└Н:╢П║У╢ЧЭ╢Я└г:▓gе╢з╣w*╢з╢л*┤'╣пз ░▒r* ноп)░D▒[▓l│u┤А╡Г╢s4[%yzD<{|Дtu|}~sXА|}БВ■0~Д·Rў┤qН@+╢П╢╡Ъ!╗╕Y╗║Y╖╝╜╢┐+╢з╢┐╢├╖╞┐▓g╚+╢з╣╩*┤+╢═W▒r╣ ║(╝6╜?╛s@tu@b|В(j┤qB *┤+╢╤W▒r ┴ ┬s tu b|_qSб*┤+╣╘L*┤'╣┌╣▐M,╣ГЩ\,╣Й└НN*┤+-╢з╣сЩ?*┤+-╢з╣х:+-╢з╣щW╗Y-╖ь:*┤-╢з╣яW*-╖їз б+╣°Ъ▓g√+╣¤╕m+╣■╕╣▒r2┼ ╞,╚<╔K╩V╦c╠s═x╧{╨Д╤а╙s4K-ГДcЕc,Lb|бtu ЧЖЗАK-ГИ ЧЖЙВ¤ъД√^·$КЛq[b*,╢ :╟K*+,╖:╗Y▓╖:*┤,╣я└:╞▓g,╣▓g!,╣#з*+,-╖&:░r.╫╪┌█#▐4▀9уEцQчTш_ъs\ =Мc4Нc#1ОПbtubРСbйzbТz_ОП[УcВQ E+гг +гг +гг()qЫг+╢*╢06-╢5Ъ-╢8Щ;*-╖;*+,╖:*┤,╣яW▓g?,╣#╗Y▓╖:зF-▓A▓G╢J6Ъ╗NYP╖R┐*+-╖S*-╖W▓g[,╣#╗Y-▓]╖:*┤`╢d╖h░rNя ёЄїў∙&·3№?¤N■Q ]bmszЖФаsf &(МcNФП]7ХЦгtuгРСгйzгУcгТz ЪЧЦФФПВ&№<¤ &+ггYZq╠L+╢k╣}N-╣ГЩ;-╣Й└o:*┤/╢q,+╢u╢x6Ъ*┤#╢q+╢u╣~з ┬▒r"),16HKs41ШЦ*ЩЪLtuLbcLТzВ№ Д=·▀>qН2+╢k╣}M,╣ГЩ!,╣Й└oN*┤#-╢q+╢u╣~з ▄▒r .!1"s ЩЪ2tu2bcВ№ Д·&qа К+╢*╢0>Ъ*┤+,╣х:з╗ДY╖Ж:Щз*┤U6╗НY,▓З*┤Q╖Н:+╢*╢РЩ*+╖У:╗Y╖Ч:з╗Y╖ь:╢Ъ*┤'╣Э░r:%()+$.20E2O3V4f5i6w9|:З;spЫДVЬЭfМcКtuКРСКйzВЮЦwМc$fЫД2XЯXEEа|АЫИ$fЫИВ2№¤бC¤8Н +гбНUVqй'+╢*╢0>+╢*╢РЩ *+╖У:з:,╢а▒r?ABDF&Gs>ЬЭ'tu'РС'bcЮЦЬЭВ№№┬ХЦqв6+╢д╢и╕оM+╢д╢┤N+╢*╢╖6+╢*╢║╕╜:╗┬Y-,╖─░rJKLM(Ns>6tu6РС+гд#╢zеЦ(жз qB*┤+╣╟└░rRstuиzй>qm+╢╩+╢═Щ*+╖;з*+╢d╢╨╖ї▒rVWX[]stubcВ =>qкH▓g╙+╢u╣╩+▓A▓╒╢J=Ъ╗NY╗║Y╖╝╪╢┐+╢┌╢├╖R┐*+╖▌*+╢u╢л▒r`abc:f?gGhs HtuHbc.кЦВ№:ноqН1*┤+╣р└M,╞!*┤,╢d╢╤W*┤Y+т,║ф╢шW▒rklno0ts 1tu1иz#лcВ№0м▌qЕC*┤╣ю╣ё║ї╣∙*║ ╣║╣∙║╣╕╣ └▀░rwxy(z2{7|BwsCtulнопq╤M▓g+╣╩+╟м*┤+╣╟└N-╟▓g+╣╩м-╢8Щ*-╖;▓g+╣╩мr2ЗИЙМ Н$О0П2Т6У:Ф?ЧKШs*MtuMйzM░Ц -▒cВ №▓│qw+╢uM+╢N-,║╢Ч░rЬЭ Юs*tu┤cиz ╡╢А ╡╖l╕=qЬL*┤M╣Щ▓g#╣%з&▓g(*┤M╣*╕-*┤M╣2╕-╣5*╖8*┤+╣;▒r"е жи%й9и>мBнKоsLtuВ":qМJ*┤╣ю╣ё║>╣∙║?╣║@╣∙║A╣*┤'Y╕BW║G╣K▒r▒▓│'┤1╡;╢I╖sJtu ╣║qE*╢П╢╡Ъзмr┤s┤|В@ ╗╝qB *╢OЪзмr▓s ┤cВ@ ╜╛qE╗RY*+╢T+╢Y╖\░rЮsиz┐└ ┴┬q4*╢_░r pqsлc├─╞q, ╕b│7╕f│g▒r 7Д╟╚╔Д ╩╤╥╤╩╒╓┌╩▄▌р╩стц╩╒чъ╩сыь╩╒юё╩╒єЎ╩с°ц╩╒√№╩с■╩╒╩ R Н░ @B @┬ !