7y J \    \       \   ,  2 2 4 4 4  4 4  G G 4       \    \ loggerLorg/slf4j/Logger;instanceLpl/ttpsc/redis/RedisModule;redisson!Lorg/redisson/api/RedissonClient; environmentLjava/lang/String;()VCodeLineNumberTableLocalVariableTablethisconnect(Ljava/lang/String;)V connectionconfigLorg/redisson/config/Config;eLjava/lang/Exception;endpoint StackMapTable endConnection getString&(Ljava/lang/String;)Ljava/lang/String;keybucketLorg/redisson/api/RBucket;LocalVariableTypeTable.Lorg/redisson/api/RBucket;getThingworxClientApplication$(Ljava/lang/String;)Ljava/util/List;thingworxClientApplication+Lpl/ttpsc/redis/ThingworxClientApplication;4Lcom/fasterxml/jackson/core/JsonProcessingException; listenersJthingworxClientApplicationsLjava/util/List; instancesiI$exLjava/lang/Throwable;appInstanceListNameInRedis=Ljava/util/List;$Ljava/util/List; SignatureQ(Ljava/lang/String;)Ljava/util/List;addInstanceToRedisList'(Ljava/lang/String;Ljava/lang/String;)VthingworxClientApplicationList jsonValue:updateThingworxClientApplicationInstanceElementInRedisList((Ljava/lang/String;ILjava/lang/String;)Vindex setStringvalue getInstance()Lpl/ttpsc/redis/RedisModule; SourceFileRedisModule.java#pl/ttpsc/ThingworxDataFetcherLambda jk bcCreating connection to redis   org/redisson/config/Config#org/redisson/codec/JsonJacksonCodec  hiDEV redis://172.17.0.2:6379  ! "#!Using local redis instance at: {} $PRODBootstrapMethods%& '{ ()java/lang/String* +,#Using redis cluster instance at: {}`Not defined ENVIRONMENT in system variables. You need to add ENVIRONMENT=DEV or ENVIRONMENT=PROD - ./ 01 fgConnected to redisjava/lang/Exception Couldn't connect to redis at: {} .$2 3 4kDisconnected from redis$Couldn't end connection to redis: {}5 67 89: ;<2Reading Thingworx client applications from list {}java/util/ArrayList => ?@ A B<+com/fasterxml/jackson/databind/ObjectMapper)pl/ttpsc/redis/ThingworxClientApplication CD EF6Thingworx client application instance read from redis:Instance name: {} GHInstance list index: {} IJK LInstance Things client ids: {} MNInstance instanceIsDead: {} O2com/fasterxml/jackson/core/JsonProcessingException3Couldn't parse json from redis list into object: {} PQR STU VTjava/lang/Long WX&Number of subscribers for topic {}: {}java/lang/Object Y Z [\1No alive appInstanceListNameInRedis for topic: {} ] ^$CMore than one appInstanceListNameInRedis is subscribed to topic: {} _java/lang/InterruptedException'java/util/concurrent/ExecutionExceptionPException thrown while waiting to read appInstanceListNameInRedis redis list: {}java/lang/Throwable` abc de fg depl/ttpsc/redis/RedisModuleh 'ij kl ENVIRONMENTm n{java/util/Listjava/util/Iteratororg/slf4j/LoggerisDebugEnabled()Zjava/lang/BooleanvalueOf(Z)Ljava/lang/Boolean;debug'(Ljava/lang/String;Ljava/lang/Object;)VsetCodec?(Lorg/redisson/client/codec/Codec;)Lorg/redisson/config/Config;equals(Ljava/lang/Object;)ZuseSingleServer*()Lorg/redisson/config/SingleServerConfig;&org/redisson/config/SingleServerConfig setAddress<(Ljava/lang/String;)Lorg/redisson/config/SingleServerConfig;9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V op redis://makeConcatWithConstantsuseClusterServers,()Lorg/redisson/config/ClusterServersConfig;(org/redisson/config/ClusterServersConfigaddNodeAddress?([Ljava/lang/String;)Lorg/redisson/config/ClusterServersConfig;isErrorEnablederrororg/redisson/Redissoncreate?(Lorg/redisson/config/Config;)Lorg/redisson/api/RedissonClient;org/redisson/api/RedissonClient isShutdownshutdown%org/redisson/client/codec/StringCodecINSTANCE'Lorg/redisson/client/codec/StringCodec; getBucketO(Ljava/lang/String;Lorg/redisson/client/codec/Codec;)Lorg/redisson/api/RBucket;org/redisson/api/RBucketget()Ljava/lang/Object;getList,(Ljava/lang/String;)Lorg/redisson/api/RList;iterator()Ljava/util/Iterator;hasNextnext readValue7(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;setIndexInRedisList(I)VgetInstanceName()Ljava/lang/String;getIndexInRedisList()Ijava/lang/Integer(I)Ljava/lang/Integer; getThingNames()Ljava/util/List;getInstanceIsDeadgetTopic-(Ljava/lang/String;)Lorg/redisson/api/RTopic;org/redisson/api/RTopiccountSubscribersAsync()Lorg/redisson/api/RFuture;org/redisson/api/RFutureawait longValue()J(J)Ljava/lang/Long;((Ljava/lang/String;[Ljava/lang/Object;)VsetInstanceDead(Z)V isWarnEnabledwarnadd lombok/Lombok sneakyThrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;org/redisson/api/RListfastSet(ILjava/lang/Object;)Vset(Ljava/lang/Object;)V::LAMBDA_BODY%(Ljava/lang/Class;)Ljava/lang/String;org/slf4j/LoggerFactory getLogger&(Ljava/lang/String;)Lorg/slf4j/Logger;java/lang/Systemgetenvq 'u$java/lang/invoke/StringConcatFactorywLookup InnerClasses(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;x%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!\Jbcde fghi jkl3*m #$n oepqlY M, Y W 3 (N,-W-Y > 3+N,Y-SW-, M",#,!x_@\!mN/01)3:4=5F6_7p8w9:<?@DABCEn>="riw)ristuvoewiyklE$ %&L'+#+(+!x(B!m"N OP(U+R,SBTDVn,uvEoez{lk+()M,*m _ `n oe|i }~  }l ++,Y-M+.N6-/:01:2Y3454:6789:;<=>?@:B#9CDEFGH7IJY9SYKSYSL MN &N9OPM$ Q9OP,RW:U#X,M,IAISITVxu 3\\A4_) \!\Vm"noq(s+tIx\yczx{|}~)U\ellnz \u)uvI|i(+oei(lS+.,XWm n oeiil]+.-Ym n*oeiilw+()N-,Zm n*oe|ii }~  } l[mklH$\]^\Y_[`a m  !t rvs