We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents bbf0aae + caba8b8 commit 427d502Copy full SHA for 427d502
src/test/java/com/rabbitmq/client/test/server/XDeathHeaderGrowth.java
@@ -28,7 +28,6 @@
28
import java.util.UUID;
29
import java.util.concurrent.CountDownLatch;
30
import java.util.concurrent.TimeUnit;
31
-import java.util.concurrent.atomic.AtomicInteger;
32
import java.util.concurrent.atomic.AtomicLong;
33
34
import org.junit.Test;
@@ -41,10 +40,9 @@
41
40
42
class RejectingConsumer extends DefaultConsumer {
43
private CountDownLatch latch;
44
- private volatile Map<String, Object> headers;
+ private Map<String, Object> headers;
45
private AtomicLong counter;
46
47
-
48
public RejectingConsumer(Channel channel, CountDownLatch latch) {
49
super(channel);
50
this.latch = latch;
0 commit comments