Author: kwall
Date: Fri Apr 20 11:00:30 2012
New Revision: 1328319
URL: http://svn.apache.org/viewvc?rev=1328319&view=rev
Log:
QPID-3936: add more debug logs
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/message/CreateParticpantCommand.java
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java?rev=1328319&r1=1328318&r2=1328319&view=diff
==============================================================================
---
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java
(original)
+++
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/Client.java
Fri Apr 20 11:00:30 2012
@@ -103,6 +103,10 @@ public class Client
public void processInstruction(final Command command)
{
+ if (LOGGER.isInfoEnabled())
+ {
+ LOGGER.info("Client " + getClientName() + " received command: " +
command);
+ }
String responseMessage = null;
try
{
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java?rev=1328319&r1=1328318&r2=1328319&view=diff
==============================================================================
---
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
(original)
+++
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ConsumerParticipant.java
Fri Apr 20 11:00:30 2012
@@ -143,6 +143,10 @@ public class ConsumerParticipant impleme
if (!batchEnabled || batchComplete)
{
+ if (LOGGER.isTraceEnabled() && batchEnabled)
+ {
+ LOGGER.trace("Committing: batch size " +
_command.getBatchSize() );
+ }
_jmsDelegate.commitOrAcknowledgeMessage(message,
_command.getSessionName());
}
@@ -161,6 +165,11 @@ public class ConsumerParticipant impleme
if (batchEnabled && !batchComplete)
{
+ if (LOGGER.isTraceEnabled())
+ {
+ LOGGER.trace("Committing: batch size " +
_command.getBatchSize() );
+ }
+
// commit/acknowledge remaining messages if necessary
_jmsDelegate.commitOrAcknowledgeMessage(message,
_command.getSessionName());
}
@@ -232,4 +241,10 @@ public class ConsumerParticipant impleme
{
return _command.getParticipantName();
}
+
+ @Override
+ public String toString()
+ {
+ return "ConsumerParticipant [_command=" + _command + ", _startTime=" +
_startTime + "]";
+ }
}
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java?rev=1328319&r1=1328318&r2=1328319&view=diff
==============================================================================
---
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java
(original)
+++
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ParticipantExecutor.java
Fri Apr 20 11:00:30 2012
@@ -94,6 +94,10 @@ public class ParticipantExecutor
ParticipantResult result = null;
try
{
+ if (LOGGER.isInfoEnabled())
+ {
+ LOGGER.info("About to run participant " + _participant);
+ }
result = _participant.doIt(_client.getClientName());
}
catch (Throwable t)
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java?rev=1328319&r1=1328318&r2=1328319&view=diff
==============================================================================
---
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java
(original)
+++
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/client/ProducerParticipant.java
Fri Apr 20 11:00:30 2012
@@ -88,6 +88,10 @@ public class ProducerParticipant impleme
if (batchLimitReached)
{
+ if (LOGGER.isTraceEnabled() && _command.getBatchSize() > 0)
+ {
+ LOGGER.trace("Committing: batch size " +
_command.getBatchSize() );
+ }
_jmsDelegate.commitOrAcknowledgeMessage(lastPublishedMessage,
_command.getSessionName());
if (_command.getInterval() > 0)
@@ -107,6 +111,10 @@ public class ProducerParticipant impleme
// commit the remaining batch messages
if (_command.getBatchSize() > 0 && numberOfMessagesSent %
_command.getBatchSize() != 0)
{
+ if (LOGGER.isTraceEnabled())
+ {
+ LOGGER.trace("Committing: batch size " +
_command.getBatchSize() );
+ }
_jmsDelegate.commitOrAcknowledgeMessage(lastPublishedMessage,
_command.getSessionName());
}
@@ -155,4 +163,10 @@ public class ProducerParticipant impleme
{
return _command.getParticipantName();
}
+
+ @Override
+ public String toString()
+ {
+ return "ProducerParticipant [command=" + _command + "]";
+ }
}
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java?rev=1328319&r1=1328318&r2=1328319&view=diff
==============================================================================
---
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java
(original)
+++
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java
Fri Apr 20 11:00:30 2012
@@ -191,7 +191,10 @@ public class ClientJmsDelegate
command);
}
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());
+
addSession(command.getSessionName(), newSession);
}
catch (final JMSException jmse)
Modified:
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/message/CreateParticpantCommand.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/message/CreateParticpantCommand.java?rev=1328319&r1=1328318&r2=1328319&view=diff
==============================================================================
---
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/message/CreateParticpantCommand.java
(original)
+++
qpid/trunk/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/message/CreateParticpantCommand.java
Fri Apr 20 11:00:30 2012
@@ -19,6 +19,8 @@
*/
package org.apache.qpid.disttest.message;
+import org.apache.commons.lang.builder.ToStringBuilder;
+
public abstract class CreateParticpantCommand extends Command
{
private String _participantName;
@@ -93,4 +95,9 @@ public abstract class CreateParticpantCo
_maximumDuration = maximumDuration;
}
+ @Override
+ public String toString()
+ {
+ return ToStringBuilder.reflectionToString(this);
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
