File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change 55
55
public class Tracer implements Runnable {
56
56
private static boolean property (String property ){
57
57
return Boolean .parseBoolean (System .getProperty (
58
- "com.rabbitmq.tools.Tracer." + property ));
58
+ "com.rabbitmq.tools.Tracer." + property ));
59
59
}
60
60
61
61
public static final boolean WITHHOLD_INBOUND_HEARTBEATS =
@@ -212,7 +212,7 @@ public void run() {
212
212
}
213
213
214
214
public void log (String message ){
215
- logger .log ("" + System .currentTimeMillis () + ": conn#"
215
+ logger .log ("" + System .currentTimeMillis () + ": conn#"
216
216
+ id + " " + message );
217
217
}
218
218
@@ -243,8 +243,8 @@ public Frame readFrame() throws IOException {
243
243
}
244
244
245
245
public void report (int channel , Object object ) {
246
- Tracer .this .log ("ch#" + channel
247
- + (inBound ? " -> " : " <- " )
246
+ Tracer .this .log ("ch#" + channel
247
+ + (inBound ? " -> " : " <- " )
248
248
+ object );
249
249
}
250
250
@@ -307,7 +307,7 @@ public void doFrame() throws IOException {
307
307
AMQCommand cmd = c .handleFrame (f );
308
308
if (cmd != null ) {
309
309
report (f .channel , cmd .toString (SUPPRESS_COMMAND_BODIES ));
310
- assemblers .remove (f .channel );
310
+ assemblers .remove (f .channel );
311
311
}
312
312
}
313
313
}
You can’t perform that action at this time.
0 commit comments