8000 Merge pull request #184 from abousselmi/master · ThinkLib/rabbitmq-java-client@d352e28 · GitHub
[go: up one dir, main page]

Skip to content

Commit d352e28

Browse files
authored
Merge pull request rabbitmq#184 from abousselmi/master
Add test ID to final output messages.
2 parents 8ac4e52 + f17134e commit d352e28

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/test/java/com/rabbitmq/examples/PerfTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,8 @@ public static void main(String[] args) {
8383
producerCount > 0,
8484
consumerCount > 0,
8585
(flags.contains("mandatory") ||
86-
flags.contains("immediate")),
87-
confirm != -1);
86+
flags.contains("immediate")),
87+
confirm != -1);
8888

8989
ConnectionFactory factory = new ConnectionFactory();
9090
factory.setShutdownTimeout(0); // So we still shut down even with slow consumers
@@ -245,13 +245,13 @@ private String getRate(String descr, long count, boolean display,
245245
public void printFinal() {
246246
long now = System.currentTimeMillis();
247247

248-
System.out.println("sending rate avg: " +
248+
System.out.println("id: " + testID + ", sending rate avg: " +
249249
formatRate(sendCountTotal * 1000.0 / (now - startTime)) +
250250
" msg/s");
251251

252252
long elapsed = now - startTime;
253253
if (elapsed > 0) {
254-
System.out.println("recving rate avg: " +
254+
System.out.println("id: " + testID + ", recving rate avg: " +
255255
formatRate(recvCountTotal * 1000.0 / elapsed) +
256256
" msg/s");
257257
}

0 commit comments

Comments
 (0)
0