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.
1 parent bfc7a47 commit ae42117Copy full SHA for ae42117
src/main/java/com/rabbitmq/stream/impl/StreamConsumer.java
@@ -64,7 +64,7 @@ class StreamConsumer implements Consumer {
64
private final boolean sac;
65
private final OffsetSpecification initialOffsetSpecification;
66
private final Lock lock = new ReentrantLock();
67
- private boolean consuming = false;
+ private volatile boolean consuming = false;
68
69
@SuppressFBWarnings("CT_CONSTRUCTOR_THROW")
70
StreamConsumer(
0 commit comments