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