Skip to content

Commit 6235798

Browse files
author
Matthew Sackman
committed
Merging bug22332 onto default
2 parents 0c06613 + b4832f4 commit 6235798

File tree

2 files changed

+15
-10
lines changed

2 files changed

+15
-10
lines changed

src/com/rabbitmq/client/impl/AMQCommand.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,10 +200,15 @@ public void transmit(AMQChannel channel) throws IOException {
200200
}
201201

202202
@Override public String toString() {
203+
return toString(false);
204+
}
205+
206+
public String toString(boolean suppressBody){
203207
byte[] body = getContentBody();
204208
String contentStr;
205209
try {
206-
contentStr = "\"" + new String(body) + "\"";
210+
contentStr = suppressBody ? (body.length + " bytes of payload") :
211+
("\"" + new String(body) + "\"");
207212
} catch (Exception e) {
208213
contentStr = "|" + body.length + "|";
209214
}

src/com/rabbitmq/tools/Tracer.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -54,17 +54,15 @@
5454
*/
5555
public class Tracer implements Runnable {
5656
public static final boolean WITHHOLD_INBOUND_HEARTBEATS =
57-
new Boolean(System.getProperty("com.rabbitmq.tools.Tracer.WITHHOLD_INBOUND_HEARTBEATS"))
58-
.booleanValue();
57+
Boolean.parseBoolean(System.getProperty("com.rabbitmq.tools.Tracer.WITHHOLD_INBOUND_HEARTBEATS"));
5958
public static final boolean WITHHOLD_OUTBOUND_HEARTBEATS =
60-
new Boolean(System.getProperty("com.rabbitmq.tools.Tracer.WITHHOLD_OUTBOUND_HEARTBEATS"))
61-
.booleanValue();
59+
Boolean.parseBoolean(System.getProperty("com.rabbitmq.tools.Tracer.WITHHOLD_OUTBOUND_HEARTBEATS"));
6260
public static final boolean NO_ASSEMBLE_FRAMES =
63-
new Boolean(System.getProperty("com.rabbitmq.tools.Tracer.NO_ASSEMBLE_FRAMES"))
64-
.booleanValue();
61+
Boolean.parseBoolean(System.getProperty("com.rabbitmq.tools.Tracer.NO_ASSEMBLE_FRAMES"));
6562
public static final boolean NO_DECODE_FRAMES =
66-
new Boolean(System.getProperty("com.rabbitmq.tools.Tracer.NO_DECODE_FRAMES"))
67-
.booleanValue();
63+
Boolean.parseBoolean(System.getProperty("com.rabbitmq.tools.Tracer.NO_DECODE_FRAMES"));
64+
public static final boolean SUPPRESS_COMMAND_BODIES =
65+
Boolean.parseBoolean(System.getProperty("com.rabbitmq.tools.Tracer.SUPPRESS_COMMAND_BODIES"));
6866

6967
public static void main(String[] args) {
7068
int listenPort = args.length > 0 ? Integer.parseInt(args[0]) : 5673;
@@ -81,6 +79,8 @@ public static void main(String[] args) {
8179
com.rabbitmq.tools.Tracer.NO_ASSEMBLE_FRAMES);
8280
System.out.println("com.rabbitmq.tools.Tracer.NO_DECODE_FRAMES = " +
8381
com.rabbitmq.tools.Tracer.NO_DECODE_FRAMES);
82+
System.out.println("com.rabbitmq.tools.Tracer.SUPPRESS_COMMAND_BODIES = " +
83+
com.rabbitmq.tools.Tracer.SUPPRESS_COMMAND_BODIES);
8484

8585
try {
8686
ServerSocket server = new ServerSocket(listenPort);
@@ -228,7 +228,7 @@ public void doFrame() throws IOException {
228228
}
229229
AMQCommand cmd = c.handleFrame(f);
230230
if (cmd != null) {
231-
report(f.channel, cmd);
231+
report(f.channel, cmd.toString(SUPPRESS_COMMAND_BODIES));
232232
assemblers.remove(f.channel);
233233
}
234234
}

0 commit comments

Comments
 (0)