diff options
| -rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/disttest/controller/TestRunner.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/controller/TestRunner.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/controller/TestRunner.java index f81b691ea6..d07d568858 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/controller/TestRunner.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/controller/TestRunner.java @@ -133,13 +133,20 @@ public class TestRunner void sendTestSetupCommands() { List<CommandForClient> commandsForAllClients = _testInstance.createCommands(); - _commandResponseLatch = new CountDownLatch(commandsForAllClients.size()); + final int numberOfCommandsToSend = commandsForAllClients.size(); + _commandResponseLatch = new CountDownLatch(numberOfCommandsToSend); + + LOGGER.debug("About to send {} command(s)", numberOfCommandsToSend); + for (CommandForClient commandForClient : commandsForAllClients) { String configuredClientName = commandForClient.getClientName(); String registeredClientName = _participatingClients.getRegisteredNameFromConfiguredName(configuredClientName); Command command = commandForClient.getCommand(); + + LOGGER.debug("Sending command : {} ", command); + sendCommandInternal(registeredClientName, command); } } |