@@ -540,9 +540,9 @@ public String basicConsume(String queue, boolean autoAck, Map<String, Object> ar
540540
541541 @ Override
542542 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 ;
546546 }
547547
548548 @ Override
@@ -886,20 +886,20 @@ private void deleteRecordedExchange(String exchange) {
886886 this .connection .deleteRecordedExchange (exchange );
887887 }
888888
889- private void recordConsumer (String result ,
889+ private void recordConsumer (String consumerTag ,
890890 String queue ,
891891 boolean autoAck ,
892892 boolean exclusive ,
893893 Map <String , Object > arguments ,
894894 Consumer callback ) {
895895 RecordedConsumer consumer = new RecordedConsumer (this , queue ).
896896 autoAck (autoAck ).
897- consumerTag (result ).
897+ consumerTag (consumerTag ).
898898 exclusive (exclusive ).
899899 arguments (arguments ).
900900 consumer (callback );
901- this .consumerTags .add (result );
902- this .connection .recordConsumer (result , consumer );
901+ this .consumerTags .add (consumerTag );
902+ this .connection .recordConsumer (consumerTag , consumer );
903903 }
904904
905905 /**
0 commit comments