File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
src/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -85,8 +85,7 @@ public class ChannelN extends AMQChannel implements com.rabbitmq.client.Channel
8585 */
8686 public volatile ConfirmListener confirmListener = null ;
8787
88- /** Sequence number of next published message requiring confirmation.
89- */
88+ /** Sequence number of next published message requiring confirmation. */
9089 private long nextPublishSeqNo = 0L ;
9190
9291 /** Reference to the currently-active default consumer, or null if there is
@@ -95,7 +94,7 @@ public class ChannelN extends AMQChannel implements com.rabbitmq.client.Channel
9594 public volatile Consumer defaultConsumer = null ;
9695
9796 /** Set of currently unconfirmed messages (i.e. messages that have
98- * not been ack'd or nack'd by the server yet. */
97+ * not been ack'd or nack'd by the server yet. */
9998 protected volatile SortedSet <Long > unconfirmedSet =
10099 Collections .synchronizedSortedSet (new TreeSet <Long >());
101100
You can’t perform that action at this time.
0 commit comments