@@ -544,9 +544,9 @@ public String basicConsume(String queue, boolean autoAck, Map<String, Object> ar
544544
545545 @ Override
546546 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 ;
550550 }
551551
552552 @ Override
@@ -890,20 +890,20 @@ private void deleteRecordedExchange(String exchange) {
890890 this .connection .deleteRecordedExchange (exchange );
891891 }
892892
893- private void recordConsumer (String result ,
893+ private void recordConsumer (String consumerTag ,
894894 String queue ,
895895 boolean autoAck ,
896896 boolean exclusive ,
897897 Map <String , Object > arguments ,
898898 Consumer callback ) {
899899 RecordedConsumer consumer = new RecordedConsumer (this , queue ).
900900 autoAck (autoAck ).
901- consumerTag (result ).
901+ consumerTag (consumerTag ).
902902 exclusive (exclusive ).
903903 arguments (arguments ).
904904 consumer (callback );
905- this .consumerTags .add (result );
906- this .connection .recordConsumer (result , consumer );
905+ this .consumerTags .add (consumerTag );
906+ this .connection .recordConsumer (consumerTag , consumer );
907907 }
908908
909909 /**
0 commit comments