Skip to content

Commit 7a266d8

Browse files
author
David R. MacIver
committed
remove close logic (Tracer is never shut down properly so it's not useful)
1 parent d3a53f8 commit 7a266d8

File tree

1 file changed

+1
-16
lines changed

1 file changed

+1
-16
lines changed

src/com/rabbitmq/tools/Tracer.java

Lines changed: 1 addition & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,6 @@ public class Tracer implements Runnable {
7272
static class AsyncLogger extends Thread{
7373
final PrintStream ps;
7474
final LinkedBlockingQueue<Object> queue = new LinkedBlockingQueue<Object>();
75-
private static final Object CLOSE = new Object();
76-
7775
public AsyncLogger(PrintStream ps){
7876
this.ps = ps;
7977
start();
@@ -92,16 +90,7 @@ void printMessage(Object message){
9290
@Override public void run(){
9391
try {
9492
while(true){
95-
Object message = queue.take();
96-
if(message == CLOSE){
97-
while((message = queue.poll()) != null){
98-
if(message != CLOSE){
99-
printMessage(message);
100-
}
101-
}
102-
break;
103-
}
104-
printMessage(message);
93+
printMessage(queue.take());
10594
}
10695
} catch (InterruptedException interrupt){
10796
}
@@ -110,10 +99,6 @@ void printMessage(Object message){
11099
public void log(Object message){
111100
queue.add(message);
112101
}
113-
114-
public void close(){
115-
queue.add(CLOSE);
116-
}
117102
}
118103

119104
public static void main(String[] args) {

0 commit comments

Comments
 (0)