class com.netflix.hystrix.collapser.RequestBatch$2 implements rx.functions.Action0
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: com.netflix.hystrix.collapser.RequestBatch$2
super_class: java.lang.Object
{
final com.netflix.hystrix.collapser.RequestBatch this$0;
descriptor: Lcom/netflix/hystrix/collapser/RequestBatch;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private final java.util.Collection val$shardRequests;
descriptor: Ljava/util/Collection;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(com.netflix.hystrix.collapser.RequestBatch, java.util.Collection);
descriptor: (Lcom/netflix/hystrix/collapser/RequestBatch;Ljava/util/Collection;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 // com.netflix.hystrix.collapser.RequestBatch$2 this
0: .line 202
aload 0 /* this */
aload 1
putfield com.netflix.hystrix.collapser.RequestBatch$2.this$0:Lcom/netflix/hystrix/collapser/RequestBatch;
aload 0 /* this */
aload 2
putfield com.netflix.hystrix.collapser.RequestBatch$2.val$shardRequests:Ljava/util/Collection;
aload 0 /* this */
invokespecial java.lang.Object.<init>:()V
return
end local 0 // com.netflix.hystrix.collapser.RequestBatch$2 this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/netflix/hystrix/collapser/RequestBatch$2;
MethodParameters:
Name Flags
this$0 final
val$shardRequests final
public void call();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=1
start local 0 // com.netflix.hystrix.collapser.RequestBatch$2 this
0: .line 210
aconst_null
astore 1 /* e */
start local 1 // java.lang.Exception e
1: .line 211
aload 0 /* this */
getfield com.netflix.hystrix.collapser.RequestBatch$2.val$shardRequests:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 7
StackMap locals: com.netflix.hystrix.collapser.RequestBatch$2 java.lang.Exception top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.netflix.hystrix.HystrixCollapser$CollapsedRequest
astore 2 /* request */
start local 2 // com.netflix.hystrix.HystrixCollapser$CollapsedRequest request
3: .line 213
aload 2 /* request */
checkcast com.netflix.hystrix.collapser.CollapsedRequestSubject
aload 1 /* e */
new java.lang.StringBuilder
dup
ldc "No response set by "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0 /* this */
getfield com.netflix.hystrix.collapser.RequestBatch$2.this$0:Lcom/netflix/hystrix/collapser/RequestBatch;
getfield com.netflix.hystrix.collapser.RequestBatch.commandCollapser:Lcom/netflix/hystrix/collapser/HystrixCollapserBridge;
invokeinterface com.netflix.hystrix.collapser.HystrixCollapserBridge.getCollapserKey:()Lcom/netflix/hystrix/HystrixCollapserKey;
invokeinterface com.netflix.hystrix.HystrixCollapserKey.name:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " 'mapResponseToRequests' implementation."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual com.netflix.hystrix.collapser.CollapsedRequestSubject.setExceptionIfResponseNotReceived:(Ljava/lang/Exception;Ljava/lang/String;)Ljava/lang/Exception;
astore 1 /* e */
4: .line 214
goto 7
StackMap locals: com.netflix.hystrix.collapser.RequestBatch$2 java.lang.Exception com.netflix.hystrix.HystrixCollapser$CollapsedRequest java.util.Iterator
StackMap stack: java.lang.IllegalStateException
5: astore 4 /* e2 */
start local 4 // java.lang.IllegalStateException e2
6: .line 215
getstatic com.netflix.hystrix.collapser.RequestBatch.logger:Lorg/slf4j/Logger;
ldc "Partial success of 'mapResponseToRequests' resulted in IllegalStateException while setting 'No response set' Exception. Continuing ... "
aload 4 /* e2 */
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 4 // java.lang.IllegalStateException e2
end local 2 // com.netflix.hystrix.HystrixCollapser$CollapsedRequest request
7: .line 211
StackMap locals: com.netflix.hystrix.collapser.RequestBatch$2 java.lang.Exception top java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
8: .line 218
return
end local 1 // java.lang.Exception e
end local 0 // com.netflix.hystrix.collapser.RequestBatch$2 this
LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/netflix/hystrix/collapser/RequestBatch$2;
1 9 1 e Ljava/lang/Exception;
3 7 2 request Lcom/netflix/hystrix/HystrixCollapser$CollapsedRequest<TResponseType;TRequestArgumentType;>;
6 7 4 e2 Ljava/lang/IllegalStateException;
Exception table:
from to target type
3 4 5 Class java.lang.IllegalStateException
}
SourceFile: "RequestBatch.java"
EnclosingMethod: com.netflix.hystrix.collapser.RequestBatch.executeBatchIfNotAlreadyStarted:()V
NestHost: com.netflix.hystrix.collapser.RequestBatch
InnerClasses:
public abstract CollapsedRequest = com.netflix.hystrix.HystrixCollapser$CollapsedRequest of com.netflix.hystrix.HystrixCollapser
com.netflix.hystrix.collapser.RequestBatch$2