31org/elasticsearch/river/RiversService$ApplyRiversjava/lang/Object9org/elasticsearch/river/cluster/RiverClusterStateListenerRiversService.java%org/elasticsearch/river/RiversService ApplyRivers3org/elasticsearch/river/RiversService$ApplyRivers$2 3org/elasticsearch/river/RiversService$ApplyRivers$1 'org/elasticsearch/river/RiversService$1this$0'Lorg/elasticsearch/river/RiversService;*(Lorg/elasticsearch/river/RiversService;)V  ()V  this3Lorg/elasticsearch/river/RiversService$ApplyRivers;riverClusterChanged=(Lorg/elasticsearch/river/cluster/RiverClusterChangedEvent;)V/org/elasticsearch/indices/IndexMissingExceptionjava/lang/Exception  access$200S(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/cluster/ClusterService; "# $(org/elasticsearch/cluster/ClusterService& localNode0()Lorg/elasticsearch/cluster/node/DiscoveryNode; () '*8org/elasticsearch/river/cluster/RiverClusterChangedEvent,state5()Lorg/elasticsearch/river/cluster/RiverClusterState; ./ -0 access$300X(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/common/collect/ImmutableMap; 23 4-org/elasticsearch/common/collect/ImmutableMap6keySet1()Lorg/elasticsearch/common/collect/ImmutableSet; 89 7:-org/elasticsearch/common/collect/ImmutableSet<iterator()Ljava/util/Iterator; >? =@,org/elasticsearch/cluster/node/DiscoveryNodeB1org/elasticsearch/river/cluster/RiverClusterStateDjava/util/IteratorFhasNext()Z HI GJnext()Ljava/lang/Object; LM GN!org/elasticsearch/river/RiverNameProuting1()Lorg/elasticsearch/river/routing/RiversRouting; RS ET-org/elasticsearch/river/routing/RiversRoutingVS(Lorg/elasticsearch/river/RiverName;)Lorg/elasticsearch/river/routing/RiverRouting; RX WY,org/elasticsearch/river/routing/RiverRouting[node ]) \^equals(Ljava/lang/Object;)Z `a Cb closeRiver&(Lorg/elasticsearch/river/RiverName;)V de f access$600J(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/client/Client; hi j access$500;(Lorg/elasticsearch/river/RiversService;)Ljava/lang/String; lm nname()Ljava/lang/String; pq Qr_metatorg/elasticsearch/client/Clientv prepareGeth(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/elasticsearch/action/get/GetRequestBuilder; xy wz.org/elasticsearch/action/get/GetRequestBuilder|setListenerThreaded2(Z)Lorg/elasticsearch/action/ActionRequestBuilder; ~ }Y(Lorg/elasticsearch/river/RiversService$ApplyRivers;Lorg/elasticsearch/river/RiverName;)V  execute,(Lorg/elasticsearch/action/ActionListener;)V } access$800T(Lorg/elasticsearch/river/RiversService;)Lorg/elasticsearch/common/logging/ESLogger; ;unexpected failure when trying to verify river [{}] deleted)org/elasticsearch/common/logging/ESLoggerwarn=(Ljava/lang/String;Ljava/lang/Throwable;[Ljava/lang/Object;)V W@ access$900 river {} has no routing node riverName%()Lorg/elasticsearch/river/RiverName; \getName q Qtrace((Ljava/lang/String;[Ljava/lang/Object;)V  access$1000 river {} belongs to node {} containsKey a 7 access$1100 river {} is already allocatedprepareGetMetaDocumentD(Ljava/lang/String;)Lorg/elasticsearch/action/get/GetRequestBuilder; d(Lorg/elasticsearch/river/RiversService$ApplyRivers;Lorg/elasticsearch/river/routing/RiverRouting;)V  e1Lorg/elasticsearch/indices/IndexMissingException;Ljava/lang/Exception;.Lorg/elasticsearch/river/routing/RiverRouting;#Lorg/elasticsearch/river/RiverName;i$Ljava/util/Iterator;event:Lorg/elasticsearch/river/cluster/RiverClusterChangedEvent;.Lorg/elasticsearch/cluster/node/DiscoveryNode;3Lorg/elasticsearch/river/cluster/RiverClusterState;_primary setPreference }Ljava/lang/String;S(Lorg/elasticsearch/river/RiversService;Lorg/elasticsearch/river/RiversService$1;)V  x0x1)Lorg/elasticsearch/river/RiversService$1; access$1400w(Lorg/elasticsearch/river/RiversService$ApplyRivers;Ljava/lang/String;)Lorg/elasticsearch/action/get/GetRequestBuilder;CodeLocalVariableTableLineNumberTable StackMapTable SourceFile InnerClasses 4 *+*  }*%+M+1N*5;A:KOQ:-UZ:,_c`*g*k*osu{}Y*&:!:*YsSq-U:KO\:_#*YS_,c+*YSY_S*5#*YS_*s Y*C\\!p BnR7y!R}} p(k.j 7BS\+. @ ] ` y3|46 !CEG1Q\yD!G=\31W#*k*o+u{ƶ}##7D*+ͱ :*+"