diff options
| author | Keith Wall <kwall@apache.org> | 2012-06-15 13:56:48 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2012-06-15 13:56:48 +0000 |
| commit | b1a8ce50c064c05db8ffe0eb7d98cf667bc3d109 (patch) | |
| tree | ff504433a92d466762f967c2d0b8c359aff56a98 /qpid/java/perftests/src/main | |
| parent | bbbffc44b6ce962cca02b8aa0f21cc1a2b3dd551 (diff) | |
| download | qpid-python-b1a8ce50c064c05db8ffe0eb7d98cf667bc3d109.tar.gz | |
QPID-4050: reduced verbosity of logging. Also removed unnecessary imports and casts in various perftests files.
Applied patch from Philip Harvey <phil@philharveyonline.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1350623 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests/src/main')
6 files changed, 12 insertions, 13 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/ControllerRunner.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/ControllerRunner.java index aa9c582bf8..71e858b4cb 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/ControllerRunner.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/ControllerRunner.java @@ -25,7 +25,6 @@ import java.io.FileWriter; import java.io.FilenameFilter; import java.io.IOException; import java.util.ArrayList; -import java.util.Arrays; import java.util.List; import javax.naming.Context; diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java index 1d2d862301..2478b49cfd 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java @@ -103,9 +103,9 @@ public class Client public void processInstruction(final Command command) { - if (LOGGER.isInfoEnabled()) + if (LOGGER.isDebugEnabled()) { - LOGGER.info("Client " + getClientName() + " received command: " + command); + LOGGER.debug("Client " + getClientName() + " received command: " + command); } String responseMessage = null; try @@ -174,7 +174,7 @@ public class Client { if (_state.compareAndSet(ClientState.RUNNING_TEST, ClientState.READY)) { - LOGGER.info("Tearing down test on client: " + _clientJmsDelegate.getClientName()); + LOGGER.debug("Tearing down test on client: " + _clientJmsDelegate.getClientName()); _clientJmsDelegate.closeTestConnections(); } @@ -190,7 +190,7 @@ public class Client public void sendResults(ParticipantResult testResult) { _clientJmsDelegate.sendResponseMessage(testResult); - LOGGER.info("Sent test results " + testResult); + LOGGER.debug("Sent test results " + testResult); } @Override diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java index d5e307d50f..bb9ce26f7e 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java @@ -56,7 +56,7 @@ public class ParticipantExecutor { _client = client; - LOGGER.info("Starting test participant in background thread: " + this); + LOGGER.debug("Starting test participant in background thread: " + this); _executor.execute(new ParticipantRunnable()); } @@ -94,9 +94,9 @@ public class ParticipantExecutor ParticipantResult result = null; try { - if (LOGGER.isInfoEnabled()) + if (LOGGER.isDebugEnabled()) { - LOGGER.info("About to run participant " + _participant); + LOGGER.debug("About to run participant " + _participant); } result = _participant.doIt(_client.getClientName()); } 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 30595269b3..eb110a4234 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 @@ -253,7 +253,7 @@ public class TestRunner setOriginalTestDetailsOn(result); _testResult.addParticipantResult(result); - LOGGER.info("Received result " + result); + LOGGER.debug("Received result " + result); _testResultsLatch.countDown(); checkForResponseError(result); diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java index d68fc86a0e..1a0e129c64 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java @@ -193,7 +193,7 @@ public class ClientJmsDelegate final boolean transacted = command.getAcknowledgeMode() == Session.SESSION_TRANSACTED; final Session newSession = connection.createSession(transacted, command.getAcknowledgeMode()); - LOGGER.info("Created session " + command.getSessionName() + " with transacted = " + newSession.getTransacted() + " and acknowledgeMode = " + newSession.getAcknowledgeMode()); + LOGGER.debug("Created session " + command.getSessionName() + " with transacted = " + newSession.getTransacted() + " and acknowledgeMode = " + newSession.getAcknowledgeMode()); addSession(command.getSessionName(), newSession); } @@ -543,7 +543,7 @@ public class ClientJmsDelegate try { consumer.close(); - LOGGER.info("Closed test consumer " + consumerName); + LOGGER.debug("Closed test consumer " + consumerName); } catch (JMSException e) { diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java index 912ce54495..bf98dd8513 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java @@ -69,7 +69,7 @@ public class QpidQueueCreator implements QueueCreator EMPTY_QUEUE_BIND_ARGUMENTS, destination.getExchangeName(), destination, autoDelete); - LOGGER.info("Created queue " + queueConfig); + LOGGER.debug("Created queue " + queueConfig); } catch (Exception e) { @@ -86,7 +86,7 @@ public class QpidQueueCreator implements QueueCreator // use #deleteQueue. AMQDestination destination = (AMQDestination) session.createQueue(queueConfig.getName()); session.sendQueueDelete(destination.getAMQQueueName()); - LOGGER.info("Deleted queue " + queueConfig.getName()); + LOGGER.debug("Deleted queue " + queueConfig.getName()); } catch (Exception e) { |
