3%org/elasticsearch/river/RiversServicehLorg/elasticsearch/common/component/AbstractLifecycleComponent;=org/elasticsearch/common/component/AbstractLifecycleComponentRiversService.java1org/elasticsearch/river/RiversService$ApplyRivers ApplyRivers'org/elasticsearch/river/RiversService$1 +org/elasticsearch/river/RiverIndexName$Conf &org/elasticsearch/river/RiverIndexNameConfriverIndexNameLjava/lang/String;client!Lorg/elasticsearch/client/Client; threadPool)Lorg/elasticsearch/threadpool/ThreadPool;clusterService*Lorg/elasticsearch/cluster/ClusterService; typesRegistry-Lorg/elasticsearch/river/RiversTypesRegistry;injector*Lorg/elasticsearch/common/inject/Injector;riversInjectorsLjava/util/Map;^Ljava/util/Map;rivers/Lorg/elasticsearch/common/collect/ImmutableMap;sLorg/elasticsearch/common/collect/ImmutableMap;/(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/client/Client;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/river/RiversTypesRegistry;Lorg/elasticsearch/river/cluster/RiverClusterService;Lorg/elasticsearch/common/inject/Injector;)V(Lorg/elasticsearch/common/inject/Inject;/(Lorg/elasticsearch/common/settings/Settings;)V #& '%org/elasticsearch/common/collect/Maps) newHashMap()Ljava/util/HashMap; +, *-  /-org/elasticsearch/common/collect/ImmutableMap1of1()Lorg/elasticsearch/common/collect/ImmutableMap; 34 25 ! 7 indexName@(Lorg/elasticsearch/common/settings/Settings;)Ljava/lang/String; 9: ;  =  ?  A  C  E  GS(Lorg/elasticsearch/river/RiversService;Lorg/elasticsearch/river/RiversService$1;)V #I J3org/elasticsearch/river/cluster/RiverClusterServiceLadd>(Lorg/elasticsearch/river/cluster/RiverClusterStateListener;)V NO MPthis'Lorg/elasticsearch/river/RiversService;settings,Lorg/elasticsearch/common/settings/Settings;riverClusterService5Lorg/elasticsearch/river/cluster/RiverClusterService;doStart()V(org/elasticsearch/ElasticsearchExceptionZdoStopjava/lang/InterruptedException]keySet1()Lorg/elasticsearch/common/collect/ImmutableSet; _` 2a-org/elasticsearch/common/collect/ImmutableSetccopyOfG(Ljava/util/Collection;)Lorg/elasticsearch/common/collect/ImmutableSet; ef dg#java/util/concurrent/CountDownLatchisize()I kl dm(I)V #o jpiterator()Ljava/util/Iterator; rs dtjava/util/IteratorvhasNext()Z xy wznext()Ljava/lang/Object; |} w~!org/elasticsearch/river/RiverName'org/elasticsearch/threadpool/ThreadPoolgeneric!()Ljava/util/concurrent/Executor; r(Lorg/elasticsearch/river/RiversService;Lorg/elasticsearch/river/RiverName;Ljava/util/concurrent/CountDownLatch;)V # java/util/concurrent/Executorexecute(Ljava/lang/Runnable;)V await Y j riverName#Lorg/elasticsearch/river/RiverName;i$Ljava/util/Iterator;e Ljava/lang/InterruptedException;indicesTLorg/elasticsearch/common/collect/ImmutableSet;/Lorg/elasticsearch/common/collect/ImmutableSet;latch%Ljava/util/concurrent/CountDownLatch;doClose createRiver5(Lorg/elasticsearch/river/RiverName;Ljava/util/Map;)Vjava/lang/Exception java/util/Map containsKey(Ljava/lang/Object;)Z logger+Lorg/elasticsearch/common/logging/ESLogger; 0ignoring river [{}][{}] creation, already existsjava/lang/Objecttype()Ljava/lang/String; name )org/elasticsearch/common/logging/ESLoggerwarn((Ljava/lang/String;[Ljava/lang/Object;)V creating river [{}][{}]debug .org/elasticsearch/common/inject/ModulesBuilder #Y 'org/elasticsearch/river/RiverNameModule&(Lorg/elasticsearch/river/RiverName;)V # Z(Lorg/elasticsearch/common/inject/Module;)Lorg/elasticsearch/common/inject/ModulesBuilder; N #org/elasticsearch/river/RiverModule TU (Lorg/elasticsearch/river/RiverName;Ljava/util/Map;Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/river/RiversTypesRegistry;)V # +org/elasticsearch/river/RiversPluginsModule(org/elasticsearch/plugins/PluginsService(org/elasticsearch/common/inject/Injector getInstance%(Ljava/lang/Class;)Ljava/lang/Object; Y(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/plugins/PluginsService;)V # createChildInjectorV(Lorg/elasticsearch/common/inject/Injector;)Lorg/elasticsearch/common/inject/Injector; put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; org/elasticsearch/river/River+org/elasticsearch/common/collect/MapBuilder newMapBuilder>(Ljava/util/Map;)Lorg/elasticsearch/common/collect/MapBuilder; S(Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/MapBuilder;  immutableMap 4 start Y 1org/elasticsearch/common/xcontent/XContentFactory jsonBuilder5()Lorg/elasticsearch/common/xcontent/XContentBuilder;  1org/elasticsearch/common/xcontent/XContentBuilder startObject  nodeG(Ljava/lang/String;)Lorg/elasticsearch/common/xcontent/XContentBuilder;   id (org/elasticsearch/cluster/ClusterService localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode;  ,org/elasticsearch/cluster/node/DiscoveryNode  fieldY(Ljava/lang/String;Ljava/lang/String;)Lorg/elasticsearch/common/xcontent/XContentBuilder;   transport_addressaddress7()Lorg/elasticsearch/common/transport/TransportAddress; !" #toString % & endObject ( )_status+org/elasticsearch/client/Client- prepareIndexl(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/elasticsearch/action/index/IndexRequestBuilder; /0 .1.org/elasticsearch/action/WriteConsistencyLevel3ONE0Lorg/elasticsearch/action/WriteConsistencyLevel; 56 472org/elasticsearch/action/index/IndexRequestBuilder9setConsistencyLevelf(Lorg/elasticsearch/action/WriteConsistencyLevel;)Lorg/elasticsearch/action/index/IndexRequestBuilder; ;< := setSourcei(Lorg/elasticsearch/common/xcontent/XContentBuilder;)Lorg/elasticsearch/action/index/IndexRequestBuilder; ?@ :A3()Lorg/elasticsearch/action/ListenableActionFuture; C :D/org/elasticsearch/action/ListenableActionFutureF actionGet H} GIfailed to create river [{}][{}]K=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V M NerrorP"org/elasticsearch/ExceptionsHelperRdetailedMessage)(Ljava/lang/Throwable;)Ljava/lang/String; TU SV0failed to write failed status for river creationXmodules0Lorg/elasticsearch/common/inject/ModulesBuilder; indexInjectorriverLorg/elasticsearch/river/River;builder3Lorg/elasticsearch/common/xcontent/XContentBuilder;e1Ljava/lang/Exception;5Ljava/util/Map; closeRiverremove&(Ljava/lang/Object;)Ljava/lang/Object; ef g&org/elasticsearch/river/RiverExceptionimissingk8(Lorg/elasticsearch/river/RiverName;Ljava/lang/String;)V #m jnclosing river [{}][{}]p$(Ljava/util/Map;)Ljava/util/HashMap; +r *s@(Ljava/util/Map;)Lorg/elasticsearch/common/collect/ImmutableMap; eu 2vjava/lang/Throwablexclose zY {)org/elasticsearch/common/inject/Injectors}-(Lorg/elasticsearch/common/inject/Injector;)V z ~tmpMapSLjava/util/Map; riverInjector access$100T(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/common/logging/ESLogger;x0 access$200S(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/cluster/ClusterService; access$300X(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/common/collect/ImmutableMap; access$400 access$500;(Lorg/elasticsearch/river/RiversService;)Ljava/lang/String; access$600J(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/client/Client; access$700 access$800 access$900 access$1000 access$1100 access$1200 access$1300 access$1500R(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/threadpool/ThreadPool; access$1600 access$1700 SignatureCodeLocalVariableTableLineNumberTableRuntimeVisibleAnnotations ExceptionsLocalVariableTypeTable StackMapTable[(Lorg/elasticsearch/river/RiverName;Ljava/util/Map;)V SourceFile InnerClasses!B !"#$F*+(*.0*68*+<>*,@*-B*D*F*HY*KQRFRSFTUFFFFFVWF. SM OTU V%W+X1Y7ZE[%XY+ RS_[\YS*8bhLjY+nqM+uN-{(-:*B Y*,,NJNQ^>0.RSRS H<  H& c de0fGrJtNwQuRxdjw-F^[Y+ RS|[!&*0+!*Y+SY+S*Y+SY+SYN-Y+̶W-Y+,**FֶW-Y**HڹڷW-*H:*0+W:**8+8:  W*DW*DW *D$'W*W*W*@*>+,28>BEJWN*L-Y+SY+SO:Q-WW  W*DW*DW *D$'W*W*W*@*>+,28>BEJW:*Y-OHX[{f PZ[\]^_`_`ab\b&RS&&T &Tc% *+HP]s $*0X[\{%"+/[!dSz*YM*0+hN-jY+lo*qY+SY+S*8t:+h:*w8,ç :,|*Haddhd4IzRSzhV$]^ I2 "@IV_kry3"Ay[/* S?/*D S?/*8 S?/* S?/*> S?/*@ S?/* S?/* S?/* S?/* S?/* S?/* S?/* S?/*B S?/* S?/* S?