Skip to content
This repository was archived by the owner on Jul 1, 2022. It is now read-only.

Commit 2be525b

Browse files
authored
Fix dead loop in QueueProcessor (#763)
Signed-off-by: Yaoliang Chen <[email protected]>
1 parent 62383c2 commit 2be525b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

jaeger-core/src/main/java/io/jaegertracing/internal/reporters/RemoteReporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ public void execute() throws SenderException {
167167
*/
168168
@ToString
169169
class QueueProcessor implements Runnable {
170-
private boolean open = true;
170+
private volatile boolean open = true;
171171
private final Set<Class<?>> commandFailedBefore = new HashSet<Class<?>>();
172172

173173
@Override

0 commit comments

Comments
 (0)