public class com.netflix.hystrix.config.HystrixConfigurationStream
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.netflix.hystrix.config.HystrixConfigurationStream
super_class: java.lang.Object
{
private final int intervalInMilliseconds;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final rx.Observable<com.netflix.hystrix.config.HystrixConfiguration> allConfigurationStream;
descriptor: Lrx/Observable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lrx/Observable<Lcom/netflix/hystrix/config/HystrixConfiguration;>;
private final java.util.concurrent.atomic.AtomicBoolean isSourceCurrentlySubscribed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private static final com.netflix.config.DynamicIntProperty dataEmissionIntervalInMs;
descriptor: Lcom/netflix/config/DynamicIntProperty;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final rx.functions.Func1<java.lang.Long, com.netflix.hystrix.config.HystrixConfiguration> getAllConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Ljava/lang/Long;Lcom/netflix/hystrix/config/HystrixConfiguration;>;
private static final com.netflix.hystrix.config.HystrixConfigurationStream INSTANCE;
descriptor: Lcom/netflix/hystrix/config/HystrixConfigurationStream;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final rx.functions.Func1<java.lang.Long, java.util.Map<com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.config.HystrixCommandConfiguration>> getAllCommandConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Ljava/lang/Long;Ljava/util/Map<Lcom/netflix/hystrix/HystrixCommandKey;Lcom/netflix/hystrix/config/HystrixCommandConfiguration;>;>;
private static final rx.functions.Func1<java.lang.Long, java.util.Map<com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.config.HystrixThreadPoolConfiguration>> getAllThreadPoolConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Ljava/lang/Long;Ljava/util/Map<Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/config/HystrixThreadPoolConfiguration;>;>;
private static final rx.functions.Func1<java.lang.Long, java.util.Map<com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.config.HystrixCollapserConfiguration>> getAllCollapserConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Ljava/lang/Long;Ljava/util/Map<Lcom/netflix/hystrix/HystrixCollapserKey;Lcom/netflix/hystrix/config/HystrixCollapserConfiguration;>;>;
private static final rx.functions.Func1<com.netflix.hystrix.config.HystrixConfiguration, java.util.Map<com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.config.HystrixCommandConfiguration>> getOnlyCommandConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Lcom/netflix/hystrix/config/HystrixConfiguration;Ljava/util/Map<Lcom/netflix/hystrix/HystrixCommandKey;Lcom/netflix/hystrix/config/HystrixCommandConfiguration;>;>;
private static final rx.functions.Func1<com.netflix.hystrix.config.HystrixConfiguration, java.util.Map<com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.config.HystrixThreadPoolConfiguration>> getOnlyThreadPoolConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Lcom/netflix/hystrix/config/HystrixConfiguration;Ljava/util/Map<Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/config/HystrixThreadPoolConfiguration;>;>;
private static final rx.functions.Func1<com.netflix.hystrix.config.HystrixConfiguration, java.util.Map<com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.config.HystrixCollapserConfiguration>> getOnlyCollapserConfig;
descriptor: Lrx/functions/Func1;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lrx/functions/Func1<Lcom/netflix/hystrix/config/HystrixConfiguration;Ljava/util/Map<Lcom/netflix/hystrix/HystrixCollapserKey;Lcom/netflix/hystrix/config/HystrixCollapserConfiguration;>;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: invokestatic com.netflix.config.DynamicPropertyFactory.getInstance:()Lcom/netflix/config/DynamicPropertyFactory;
ldc "hystrix.stream.config.intervalInMilliseconds"
sipush 5000
invokevirtual com.netflix.config.DynamicPropertyFactory.getIntProperty:(Ljava/lang/String;I)Lcom/netflix/config/DynamicIntProperty;
1: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.dataEmissionIntervalInMs:Lcom/netflix/config/DynamicIntProperty;
2: new com.netflix.hystrix.config.HystrixConfigurationStream$1
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$1.<init>:()V
3: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getAllConfig:Lrx/functions/Func1;
4: new com.netflix.hystrix.config.HystrixConfigurationStream
dup
getstatic com.netflix.hystrix.config.HystrixConfigurationStream.dataEmissionIntervalInMs:Lcom/netflix/config/DynamicIntProperty;
invokevirtual com.netflix.config.DynamicIntProperty.get:()I
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream.<init>:(I)V
5: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.INSTANCE:Lcom/netflix/hystrix/config/HystrixConfigurationStream;
6: new com.netflix.hystrix.config.HystrixConfigurationStream$2
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$2.<init>:()V
7: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getAllCommandConfig:Lrx/functions/Func1;
8: new com.netflix.hystrix.config.HystrixConfigurationStream$3
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$3.<init>:()V
9: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getAllThreadPoolConfig:Lrx/functions/Func1;
10: new com.netflix.hystrix.config.HystrixConfigurationStream$4
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$4.<init>:()V
11: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getAllCollapserConfig:Lrx/functions/Func1;
12: new com.netflix.hystrix.config.HystrixConfigurationStream$5
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$5.<init>:()V
13: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getOnlyCommandConfig:Lrx/functions/Func1;
14: new com.netflix.hystrix.config.HystrixConfigurationStream$6
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$6.<init>:()V
15: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getOnlyThreadPoolConfig:Lrx/functions/Func1;
16: new com.netflix.hystrix.config.HystrixConfigurationStream$7
dup
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$7.<init>:()V
17: putstatic com.netflix.hystrix.config.HystrixConfigurationStream.getOnlyCollapserConfig:Lrx/functions/Func1;
18: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield com.netflix.hystrix.config.HystrixConfigurationStream.isSourceCurrentlySubscribed:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
iload 1
putfield com.netflix.hystrix.config.HystrixConfigurationStream.intervalInMilliseconds:I
3: aload 0
iload 1
i2l
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic rx.Observable.interval:(JLjava/util/concurrent/TimeUnit;)Lrx/Observable;
4: getstatic com.netflix.hystrix.config.HystrixConfigurationStream.getAllConfig:Lrx/functions/Func1;
invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
5: new com.netflix.hystrix.config.HystrixConfigurationStream$8
dup
aload 0
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$8.<init>:(Lcom/netflix/hystrix/config/HystrixConfigurationStream;)V
invokevirtual rx.Observable.doOnSubscribe:(Lrx/functions/Action0;)Lrx/Observable;
6: new com.netflix.hystrix.config.HystrixConfigurationStream$9
dup
aload 0
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream$9.<init>:(Lcom/netflix/hystrix/config/HystrixConfigurationStream;)V
invokevirtual rx.Observable.doOnUnsubscribe:(Lrx/functions/Action0;)Lrx/Observable;
7: invokevirtual rx.Observable.share:()Lrx/Observable;
8: invokevirtual rx.Observable.onBackpressureDrop:()Lrx/Observable;
9: putfield com.netflix.hystrix.config.HystrixConfigurationStream.allConfigurationStream:Lrx/Observable;
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
0 11 1 intervalInMilliseconds I
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
intervalInMilliseconds final
public static com.netflix.hystrix.config.HystrixConfigurationStream getInstance();
descriptor: ()Lcom/netflix/hystrix/config/HystrixConfigurationStream;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic com.netflix.hystrix.config.HystrixConfigurationStream.INSTANCE:Lcom/netflix/hystrix/config/HystrixConfigurationStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
static com.netflix.hystrix.config.HystrixConfigurationStream getNonSingletonInstanceOnlyUsedInUnitTests(int);
descriptor: (I)Lcom/netflix/hystrix/config/HystrixConfigurationStream;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.netflix.hystrix.config.HystrixConfigurationStream
dup
iload 0
invokespecial com.netflix.hystrix.config.HystrixConfigurationStream.<init>:(I)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 delayInMs I
MethodParameters:
Name Flags
delayInMs
public rx.Observable<com.netflix.hystrix.config.HystrixConfiguration> observe();
descriptor: ()Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.config.HystrixConfigurationStream.allConfigurationStream:Lrx/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
Signature: ()Lrx/Observable<Lcom/netflix/hystrix/config/HystrixConfiguration;>;
public rx.Observable<java.util.Map<com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.config.HystrixCommandConfiguration>> observeCommandConfiguration();
descriptor: ()Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.config.HystrixConfigurationStream.allConfigurationStream:Lrx/Observable;
getstatic com.netflix.hystrix.config.HystrixConfigurationStream.getOnlyCommandConfig:Lrx/functions/Func1;
invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
Signature: ()Lrx/Observable<Ljava/util/Map<Lcom/netflix/hystrix/HystrixCommandKey;Lcom/netflix/hystrix/config/HystrixCommandConfiguration;>;>;
public rx.Observable<java.util.Map<com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.config.HystrixThreadPoolConfiguration>> observeThreadPoolConfiguration();
descriptor: ()Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.config.HystrixConfigurationStream.allConfigurationStream:Lrx/Observable;
getstatic com.netflix.hystrix.config.HystrixConfigurationStream.getOnlyThreadPoolConfig:Lrx/functions/Func1;
invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
Signature: ()Lrx/Observable<Ljava/util/Map<Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/config/HystrixThreadPoolConfiguration;>;>;
public rx.Observable<java.util.Map<com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.config.HystrixCollapserConfiguration>> observeCollapserConfiguration();
descriptor: ()Lrx/Observable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.config.HystrixConfigurationStream.allConfigurationStream:Lrx/Observable;
getstatic com.netflix.hystrix.config.HystrixConfigurationStream.getOnlyCollapserConfig:Lrx/functions/Func1;
invokevirtual rx.Observable.map:(Lrx/functions/Func1;)Lrx/Observable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
Signature: ()Lrx/Observable<Ljava/util/Map<Lcom/netflix/hystrix/HystrixCollapserKey;Lcom/netflix/hystrix/config/HystrixCollapserConfiguration;>;>;
public int getIntervalInMilliseconds();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.config.HystrixConfigurationStream.intervalInMilliseconds:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
public boolean isSourceCurrentlySubscribed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.netflix.hystrix.config.HystrixConfigurationStream.isSourceCurrentlySubscribed:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/config/HystrixConfigurationStream;
private static com.netflix.hystrix.config.HystrixCommandConfiguration sampleCommandConfiguration(com.netflix.hystrix.HystrixCommandKey, com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.HystrixCommandGroupKey, com.netflix.hystrix.HystrixCommandProperties);
descriptor: (Lcom/netflix/hystrix/HystrixCommandKey;Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/HystrixCommandGroupKey;Lcom/netflix/hystrix/HystrixCommandProperties;)Lcom/netflix/hystrix/config/HystrixCommandConfiguration;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokestatic com.netflix.hystrix.config.HystrixCommandConfiguration.sample:(Lcom/netflix/hystrix/HystrixCommandKey;Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/HystrixCommandGroupKey;Lcom/netflix/hystrix/HystrixCommandProperties;)Lcom/netflix/hystrix/config/HystrixCommandConfiguration;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 commandKey Lcom/netflix/hystrix/HystrixCommandKey;
0 1 1 threadPoolKey Lcom/netflix/hystrix/HystrixThreadPoolKey;
0 1 2 groupKey Lcom/netflix/hystrix/HystrixCommandGroupKey;
0 1 3 commandProperties Lcom/netflix/hystrix/HystrixCommandProperties;
MethodParameters:
Name Flags
commandKey
threadPoolKey
groupKey
commandProperties
private static com.netflix.hystrix.config.HystrixThreadPoolConfiguration sampleThreadPoolConfiguration(com.netflix.hystrix.HystrixThreadPoolKey, com.netflix.hystrix.HystrixThreadPoolProperties);
descriptor: (Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/HystrixThreadPoolProperties;)Lcom/netflix/hystrix/config/HystrixThreadPoolConfiguration;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.netflix.hystrix.config.HystrixThreadPoolConfiguration.sample:(Lcom/netflix/hystrix/HystrixThreadPoolKey;Lcom/netflix/hystrix/HystrixThreadPoolProperties;)Lcom/netflix/hystrix/config/HystrixThreadPoolConfiguration;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 threadPoolKey Lcom/netflix/hystrix/HystrixThreadPoolKey;
0 1 1 threadPoolProperties Lcom/netflix/hystrix/HystrixThreadPoolProperties;
MethodParameters:
Name Flags
threadPoolKey
threadPoolProperties
private static com.netflix.hystrix.config.HystrixCollapserConfiguration sampleCollapserConfiguration(com.netflix.hystrix.HystrixCollapserKey, com.netflix.hystrix.HystrixCollapserProperties);
descriptor: (Lcom/netflix/hystrix/HystrixCollapserKey;Lcom/netflix/hystrix/HystrixCollapserProperties;)Lcom/netflix/hystrix/config/HystrixCollapserConfiguration;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic com.netflix.hystrix.config.HystrixCollapserConfiguration.sample:(Lcom/netflix/hystrix/HystrixCollapserKey;Lcom/netflix/hystrix/HystrixCollapserProperties;)Lcom/netflix/hystrix/config/HystrixCollapserConfiguration;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 collapserKey Lcom/netflix/hystrix/HystrixCollapserKey;
0 1 1 collapserProperties Lcom/netflix/hystrix/HystrixCollapserProperties;
MethodParameters:
Name Flags
collapserKey
collapserProperties
}
SourceFile: "HystrixConfigurationStream.java"
NestMembers:
com.netflix.hystrix.config.HystrixConfigurationStream$1 com.netflix.hystrix.config.HystrixConfigurationStream$2 com.netflix.hystrix.config.HystrixConfigurationStream$3 com.netflix.hystrix.config.HystrixConfigurationStream$4 com.netflix.hystrix.config.HystrixConfigurationStream$5 com.netflix.hystrix.config.HystrixConfigurationStream$6 com.netflix.hystrix.config.HystrixConfigurationStream$7 com.netflix.hystrix.config.HystrixConfigurationStream$8 com.netflix.hystrix.config.HystrixConfigurationStream$9
InnerClasses:
com.netflix.hystrix.config.HystrixConfigurationStream$1
com.netflix.hystrix.config.HystrixConfigurationStream$2
com.netflix.hystrix.config.HystrixConfigurationStream$3
com.netflix.hystrix.config.HystrixConfigurationStream$4
com.netflix.hystrix.config.HystrixConfigurationStream$5
com.netflix.hystrix.config.HystrixConfigurationStream$6
com.netflix.hystrix.config.HystrixConfigurationStream$7
com.netflix.hystrix.config.HystrixConfigurationStream$8
com.netflix.hystrix.config.HystrixConfigurationStream$9