[jboss-cvs] JBoss Messaging SVN: r2889 - trunk/tests/src/org/jboss/test/messaging/jms/stress.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Fri Jul 13 03:18:20 EDT 2007
Author: clebert.suconic at jboss.com
Date: 2007-07-13 03:18:19 -0400 (Fri, 13 Jul 2007)
New Revision: 2889
Modified:
trunk/tests/src/org/jboss/test/messaging/jms/stress/Receiver.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/RecoveringReceiver.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/Runner.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/Sender.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCReceiver.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCSender.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalReceiver.java
trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalSender.java
Log:
Adding tracing into Runner
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/Receiver.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/Receiver.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/Receiver.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -129,7 +129,7 @@
catch (Exception e)
{
log.error("Failed to put in channel", e);
- failed = true;
+ setFailed(true);
}
}
@@ -208,7 +208,7 @@
if (m == null)
{
log.error("Message is null");
- failed = true;
+ setFailed(true);
processingDone();
return;
}
@@ -222,7 +222,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message received not zero");
- failed = true;
+ setFailed(true);
processingDone();
return;
}
@@ -232,7 +232,7 @@
if (prevCount.intValue() != msgCount.intValue() - 1)
{
log.error("Message out of sequence for " + prodName + ", expected:" + (prevCount.intValue() + 1) + " got " + msgCount);
- failed = true;
+ setFailed(true);
processingDone();
return;
}
@@ -249,7 +249,7 @@
catch (Exception e)
{
log.error("Failed to receive message", e);
- failed = true;
+ setFailed(true);
}
finally
{
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/RecoveringReceiver.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/RecoveringReceiver.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/RecoveringReceiver.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -87,7 +87,7 @@
if (m == null)
{
log.error("Message is null");
- failed = true;
+ setFailed(true);
return;
}
String prodName = m.getStringProperty("PROD_NAME");
@@ -100,7 +100,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message from " + prodName + " is not 0, it is " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
else
@@ -114,7 +114,7 @@
if (count.lastAcked != msgCount.intValue() - 1)
{
log.error("Message out of sequence for " + prodName + ", expected " + (count.lastAcked + 1));
- failed = true;
+ setFailed(true);
return;
}
}
@@ -154,7 +154,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message from " + prodName + " is not 0, it is " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
else
@@ -169,7 +169,7 @@
if (count.lastReceived != msgCount.intValue() - 1)
{
log.error("Message out of sequence");
- failed = true;
+ setFailed(true);
return;
}
}
@@ -186,7 +186,7 @@
catch (Exception e)
{
log.error("Failed to receive message", e);
- failed = true;
+ setFailed(true);
}
}
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/Runner.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/Runner.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/Runner.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -22,6 +22,7 @@
package org.jboss.test.messaging.jms.stress;
import javax.jms.Session;
+import org.jboss.logging.Logger;
/**
*
@@ -36,11 +37,13 @@
*/
public abstract class Runner implements Runnable
{
+ protected Logger log = Logger.getLogger(getClass());
+
protected Session sess;
protected int numMessages;
- protected boolean failed;
+ private boolean failed;
public Runner(Session sess, int numMessages)
{
@@ -55,4 +58,13 @@
return failed;
}
+ public void setFailed(boolean failed)
+ {
+ this.failed = failed;
+ if (failed)
+ {
+ log.info("Marking Runner " + this + " as failed", new Exception ("trace"));
+ }
+ }
+
}
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/Sender.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/Sender.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/Sender.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -71,7 +71,7 @@
catch (Exception e)
{
log.error("Failed to send message", e);
- failed = true;
+ setFailed(true);
}
}
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCReceiver.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCReceiver.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCReceiver.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -99,7 +99,7 @@
if (m == null)
{
log.error("Message is null");
- failed = true;
+ setFailed(true);
return;
}
String prodName = m.getStringProperty("PROD_NAME");
@@ -112,7 +112,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message from " + prodName + " is not 0, it is " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
else
@@ -126,7 +126,7 @@
if (count.lastCommitted != msgCount.intValue() - 1)
{
log.error("Message out of sequence for " + prodName + ", expected " + (count.lastCommitted + 1) + ", actual " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
}
@@ -161,7 +161,7 @@
if (m == null)
{
log.error("Message is null (rollback)");
- failed = true;
+ setFailed(true);
return;
}
String prodName = m.getStringProperty("PROD_NAME");
@@ -174,7 +174,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message from " + prodName + " is not 0, it is " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
else
@@ -189,7 +189,7 @@
if (count.lastReceived != msgCount.intValue() - 1)
{
log.error("Message out of sequence");
- failed = true;
+ setFailed(true);
return;
}
}
@@ -218,7 +218,7 @@
catch (Exception e)
{
log.error("Failed to receive message", e);
- failed = true;
+ setFailed(true);
}
}
}
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCSender.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCSender.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/Transactional2PCSender.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -117,7 +117,7 @@
catch (Exception e)
{
log.error("Failed to send message", e);
- failed = true;
+ setFailed(true);
}
}
}
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalReceiver.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalReceiver.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalReceiver.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -87,7 +87,7 @@
if (m == null)
{
log.error("Message is null");
- failed = true;
+ setFailed(true);
return;
}
String prodName = m.getStringProperty("PROD_NAME");
@@ -100,7 +100,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message from " + prodName + " is not 0, it is " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
else
@@ -114,7 +114,7 @@
if (count.lastCommitted != msgCount.intValue() - 1)
{
log.error("Message out of sequence for " + m.getJMSMessageID() + " " + prodName + ", expected " + (count.lastCommitted + 1) + ", actual " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
}
@@ -142,7 +142,7 @@
if (m == null)
{
log.error("Message is null");
- failed = true;
+ setFailed(true);
return;
}
String prodName = m.getStringProperty("PROD_NAME");
@@ -155,7 +155,7 @@
if (msgCount.intValue() != 0)
{
log.error("First message from " + prodName + " is not 0, it is " + msgCount);
- failed = true;
+ setFailed(true);
return;
}
else
@@ -170,7 +170,7 @@
if (count.lastReceived != msgCount.intValue() - 1)
{
log.error("Message out of sequence");
- failed = true;
+ setFailed(true);
return;
}
}
@@ -189,7 +189,7 @@
catch (Exception e)
{
log.error("Failed to receive message", e);
- failed = true;
+ setFailed(true);
}
}
}
Modified: trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalSender.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalSender.java 2007-07-13 06:43:41 UTC (rev 2888)
+++ trunk/tests/src/org/jboss/test/messaging/jms/stress/TransactionalSender.java 2007-07-13 07:18:19 UTC (rev 2889)
@@ -89,7 +89,7 @@
catch (Exception e)
{
log.error("Failed to send message", e);
- failed = true;
+ setFailed(true);
}
}
}
More information about the jboss-cvs-commits
mailing list