You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by ke...@apache.org on 2010/08/17 21:30:05 UTC
svn commit: r986458 -
/geronimo/server/branches/2.2/testsuite/enterprise-testsuite/jms-tests/jms-ejb/src/main/java/org/apache/geronimo/jms/test/bmt/JmsBmtBean.java
Author: kevan
Date: Tue Aug 17 19:30:05 2010
New Revision: 986458
URL: http://svn.apache.org/viewvc?rev=986458&view=rev
Log:
bump up receive wait time (seem to be exceeding it). also removed unused JMS connection/session objects
Modified:
geronimo/server/branches/2.2/testsuite/enterprise-testsuite/jms-tests/jms-ejb/src/main/java/org/apache/geronimo/jms/test/bmt/JmsBmtBean.java
Modified: geronimo/server/branches/2.2/testsuite/enterprise-testsuite/jms-tests/jms-ejb/src/main/java/org/apache/geronimo/jms/test/bmt/JmsBmtBean.java
URL: http://svn.apache.org/viewvc/geronimo/server/branches/2.2/testsuite/enterprise-testsuite/jms-tests/jms-ejb/src/main/java/org/apache/geronimo/jms/test/bmt/JmsBmtBean.java?rev=986458&r1=986457&r2=986458&view=diff
==============================================================================
--- geronimo/server/branches/2.2/testsuite/enterprise-testsuite/jms-tests/jms-ejb/src/main/java/org/apache/geronimo/jms/test/bmt/JmsBmtBean.java (original)
+++ geronimo/server/branches/2.2/testsuite/enterprise-testsuite/jms-tests/jms-ejb/src/main/java/org/apache/geronimo/jms/test/bmt/JmsBmtBean.java Tue Aug 17 19:30:05 2010
@@ -101,9 +101,9 @@ public class JmsBmtBean implements JmsBm
Message received = null;
try {
conn = this.connFactory.createConnection();
- c2 = connFactory.createConnection();
+// c2 = connFactory.createConnection();
sess = conn.createSession(true, Session.SESSION_TRANSACTED);
- s2 = c2.createSession(true, Session.SESSION_TRANSACTED);
+// s2 = c2.createSession(true, Session.SESSION_TRANSACTED);
prod = sess.createProducer(destination);
consumer = sess.createConsumer(destination);
conn.start();
@@ -134,7 +134,7 @@ public class JmsBmtBean implements JmsBm
ut.begin();
try {
- received = consumer.receive(1000);
+ received = consumer.receive(2000);
if (received == null) throw new JMSException("Not received second time");
if (!to.equals(((ObjectMessage)received).getObject())) throw new JMSException("Wrong object inside: " + ((ObjectMessage)received).getObject());
} finally {
@@ -159,8 +159,8 @@ public class JmsBmtBean implements JmsBm
if (conn != null) {
conn.close();
}
- if (s2 != null) s2.close();
- if (c2 != null) c2.close();;
+// if (s2 != null) s2.close();
+// if (c2 != null) c2.close();;
} catch (JMSException e) {
logger.error("Could not finalize jms connections");
}