@@ -540,9 +540,9 @@ public String basicConsume(String queue, boolean autoAck, Map<String, Object> ar
540
540
541
541
@ Override
542
542
public String basicConsume (String queue , boolean autoAck , String consumerTag , boolean noLocal , boolean exclusive , Map <String , Object > arguments , Consumer callback ) throws IOException {
543
- final String result = delegate .basicConsume (queue , autoAck , consumerTag , noLocal , exclusive , arguments , callback );
544
- recordConsumer (result , queue , autoAck , exclusive , arguments , callback );
545
- return result ;
543
+ final String tag = delegate .basicConsume (queue , autoAck , consumerTag , noLocal , exclusive , arguments , callback );
544
+ recordConsumer (tag , queue , autoAck , exclusive , arguments , callback );
545
+ return tag ;
546
546
}
547
547
548
548
@ Override
@@ -886,20 +886,20 @@ private void deleteRecordedExchange(String exchange) {
886
886
this .connection .deleteRecordedExchange (exchange );
887
887
}
888
888
889
- private void recordConsumer (String result ,
889
+ private void recordConsumer (String consumerTag ,
890
890
String queue ,
891
891
boolean autoAck ,
892
892
boolean exclusive ,
893
893
Map <String , Object > arguments ,
894
894
Consumer callback ) {
895
895
RecordedConsumer consumer = new RecordedConsumer (this , queue ).
896
896
autoAck (autoAck ).
897
- consumerTag (result ).
897
+ consumerTag (consumerTag ).
898
898
exclusive (exclusive ).
899
899
arguments (arguments ).
900
900
consumer (callback );
901
- this .consumerTags .add (result );
902
- this .connection .recordConsumer (result , consumer );
901
+ this .consumerTags .add (consumerTag );
902
+ this .connection .recordConsumer (consumerTag , consumer );
903
903
}
904
904
905
905
/**
0 commit comments