You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2017/01/27 18:09:22 UTC
svn commit: r1780600 - in /qpid/java/trunk/systests/src:
main/java/org/apache/qpid/test/utils/
test/java/org/apache/qpid/client/failover/
test/java/org/apache/qpid/test/client/failover/
test/java/org/apache/qpid/test/unit/xa/ test/java/org/apache/qpid/...
Author: kwall
Date: Fri Jan 27 18:09:21 2017
New Revision: 1780600
URL: http://svn.apache.org/viewvc?rev=1780600&view=rev
Log:
QPID-7609: Address some review comments from Alex Rudyy <or...@apache.org>
Modified:
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/JmsProvider.java
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClient0xProvider.java
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClientProvider.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/FaultTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/QueueTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/TopicTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java
Modified: qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/JmsProvider.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/JmsProvider.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/JmsProvider.java (original)
+++ qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/JmsProvider.java Fri Jan 27 18:09:21 2017
@@ -36,8 +36,6 @@ import javax.naming.NamingException;
public interface JmsProvider
{
- InitialContext getInitialContext() throws NamingException;
-
ConnectionFactory getConnectionFactory() throws NamingException;
ConnectionFactory getConnectionFactory(Map<String, String> options) throws NamingException;
Modified: qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java (original)
+++ qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java Fri Jan 27 18:09:21 2017
@@ -217,11 +217,6 @@ public class QpidBrokerTestCase extends
}
}
- public InitialContext getInitialContext() throws NamingException
- {
- return _jmsProvider.getInitialContext();
- }
-
/**
* Get the default connection factory for the currently used broker
* Default factory is "local"
Modified: qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClient0xProvider.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClient0xProvider.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClient0xProvider.java (original)
+++ qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClient0xProvider.java Fri Jan 27 18:09:21 2017
@@ -67,12 +67,6 @@ public class QpidJmsClient0xProvider imp
}
@Override
- public InitialContext getInitialContext() throws NamingException
- {
- return new InitialContext(_initialContextEnvironment);
- }
-
- @Override
public ConnectionFactory getConnectionFactory() throws NamingException
{
if (Boolean.getBoolean(QpidBrokerTestCase.PROFILE_USE_SSL))
@@ -113,8 +107,7 @@ public class QpidJmsClient0xProvider imp
throws NamingException
{
-
- return (ConnectionFactory) getInitialContext().lookup(factoryName);
+ return (ConnectionFactory) new InitialContext(_initialContextEnvironment).lookup(factoryName);
}
@Override
Modified: qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClientProvider.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClientProvider.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClientProvider.java (original)
+++ qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidJmsClientProvider.java Fri Jan 27 18:09:21 2017
@@ -56,12 +56,6 @@ public class QpidJmsClientProvider imple
}
@Override
- public InitialContext getInitialContext() throws NamingException
- {
- return new InitialContext(_initialContextEnvironment);
- }
-
- @Override
public ConnectionFactory getConnectionFactory() throws NamingException
{
return getConnectionFactory(Collections.<String, String>emptyMap());
@@ -170,7 +164,7 @@ public class QpidJmsClientProvider imple
appendOptions(options, stem);
_initialContextEnvironment.put("connectionfactory.default.ssl", stem.toString());
}
- return (ConnectionFactory) getInitialContext().lookup(factoryName);
+ return (ConnectionFactory) new InitialContext(_initialContextEnvironment).lookup(factoryName);
}
@Override
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/failover/FailoverBehaviourTest.java Fri Jan 27 18:09:21 2017
@@ -114,7 +114,7 @@ public class FailoverBehaviourTest exten
private JMSException _exceptionListenerException;
@Override
- protected void setUp() throws Exception
+ public void setUp() throws Exception
{
super.setUp();
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/failover/FailoverTest.java Fri Jan 27 18:09:21 2017
@@ -60,7 +60,7 @@ public class FailoverTest extends Failov
private Random rand;
@Override
- protected void setUp() throws Exception
+ public void setUp() throws Exception
{
super.setUp();
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/FaultTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/FaultTest.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/FaultTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/FaultTest.java Fri Jan 27 18:09:21 2017
@@ -32,7 +32,6 @@ import javax.transaction.xa.XAException;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
-import junit.framework.TestSuite;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -66,45 +65,30 @@ public class FaultTest extends AbstractX
*/
private static QueueSession _nonXASession = null;
- /**
- * the queue name
- */
- private static final String QUEUENAME = "xaQueue";
/** ----------------------------------------------------------------------------------- **/
/**
* ----------------------------- JUnit support ----------------------------------------- *
*/
- /**
- * Gets the test suite tests
- *
- * @return the test suite tests
- */
- public static TestSuite getSuite()
- {
- return new TestSuite(QueueTest.class);
- }
-
- /**
- * Run the test suite.
- *
- * @param args Any command line arguments specified to this class.
- */
- public static void main(String args[])
- {
- junit.textui.TestRunner.run(getSuite());
- }
-
@Override
public void tearDown() throws Exception
{
- if (!isBroker08())
+ try
+ {
+ if (_xaqueueConnection != null)
+ {
+ _xaqueueConnection.close();
+ }
+ if (_queueConnection != null)
+ {
+ _queueConnection.close();
+ }
+ }
+ finally
{
- _xaqueueConnection.close();
- _queueConnection.close();
+ super.tearDown();
}
- super.tearDown();
}
/**
@@ -112,13 +96,13 @@ public class FaultTest extends AbstractX
*/
public void init() throws Exception
{
- if (!isBroker08())
+ if (isBroker010())
{
- _queue = (Queue) getInitialContext().lookup(QUEUENAME);
_queueFactory = (XAQueueConnectionFactory) getConnectionFactory();
- _xaqueueConnection = _queueFactory.createXAQueueConnection("guest", "guest");
+ _xaqueueConnection = _queueFactory.createXAQueueConnection(GUEST_USERNAME, GUEST_PASSWORD);
XAQueueSession session = _xaqueueConnection.createXAQueueSession();
- _queueConnection = _queueFactory.createQueueConnection("guest","guest");
+ _queue = session.createQueue(getTestQueueName());
+ _queueConnection = _queueFactory.createQueueConnection(GUEST_USERNAME, GUEST_PASSWORD);
_nonXASession = _queueConnection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
init(session, _queue);
}
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/QueueTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/QueueTest.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/QueueTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/QueueTest.java Fri Jan 27 18:09:21 2017
@@ -33,7 +33,6 @@ import javax.transaction.xa.XAException;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
-import junit.framework.TestSuite;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -53,12 +52,12 @@ public class QueueTest extends AbstractX
/**
* standard xa queue connection
*/
- private static XAQueueConnection _xaqueueConnection= null;
+ private static XAQueueConnection _xaqueueConnection = null;
/**
* standard xa queue connection
*/
- private static QueueConnection _queueConnection=null;
+ private static QueueConnection _queueConnection = null;
/**
@@ -66,109 +65,45 @@ public class QueueTest extends AbstractX
*/
private static QueueSession _nonXASession = null;
- /**
- * the queue name
- */
- private static final String QUEUENAME = "xaQueue";
/** ----------------------------------------------------------------------------------- **/
/**
* ----------------------------- JUnit support ----------------------------------------- *
*/
- /**
- * Gets the test suite tests
- *
- * @return the test suite tests
- */
- public static TestSuite getSuite()
- {
- return new TestSuite(QueueTest.class);
- }
-
- /**
- * Run the test suite.
- *
- * @param args Any command line arguments specified to this class.
- */
- public static void main(String args[])
- {
- junit.textui.TestRunner.run(getSuite());
- }
-
+ @Override
public void tearDown() throws Exception
{
- if (!isBroker08())
+ try
{
- try
+ if (_xaqueueConnection != null)
{
_xaqueueConnection.close();
- _queueConnection.close();
}
- catch (Exception e)
+ if (_queueConnection != null)
{
- fail("Exception thrown when cleaning standard connection: " + e.getStackTrace());
+ _queueConnection.close();
}
}
- super.tearDown();
+ finally
+ {
+ super.tearDown();
+ }
}
/**
* Initialize standard actors
*/
- public void init()
+ public void init() throws Exception
{
if (!isBroker08())
{
- // lookup test queue
- try
- {
- _queue = (Queue) getInitialContext().lookup(QUEUENAME);
- }
- catch (Exception e)
- {
- fail("cannot lookup test queue " + e.getMessage());
- }
-
- // lookup connection factory
- try
- {
- _queueFactory = (XAQueueConnectionFactory) getConnectionFactory();
- }
- catch (Exception e)
- {
- fail("enable to lookup connection factory ");
- }
- // create standard connection
- try
- {
- _xaqueueConnection= getNewQueueXAConnection();
- }
- catch (JMSException e)
- {
- fail("cannot create queue connection: " + e.getMessage());
- }
- // create xa session
- XAQueueSession session = null;
- try
- {
- session = _xaqueueConnection.createXAQueueSession();
- }
- catch (JMSException e)
- {
- fail("cannot create queue session: " + e.getMessage());
- }
- // create a standard session
- try
- {
- _queueConnection = _queueFactory.createQueueConnection("guest", "guest");
- _nonXASession = _queueConnection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
- }
- catch (JMSException e)
- {
- _logger.error("cannot create queue session",e);
- fail("cannot create queue session: " + e.getMessage());
- }
+ _queueFactory = (XAQueueConnectionFactory) getConnectionFactory();
+ _xaqueueConnection= getNewQueueXAConnection();
+ final XAQueueSession session = _xaqueueConnection.createXAQueueSession();
+ _queue = session.createQueue(getTestQueueName());
+ _queueConnection = _queueFactory.createQueueConnection(GUEST_USERNAME, GUEST_PASSWORD);
+ _nonXASession = _queueConnection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
init(session, _queue);
}
}
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/TopicTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/TopicTest.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/TopicTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/xa/TopicTest.java Fri Jan 27 18:09:21 2017
@@ -26,7 +26,6 @@ import javax.transaction.xa.XAException;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
-import junit.framework.TestSuite;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -77,26 +76,7 @@ public class TopicTest extends AbstractX
/** ----------------------------- JUnit support ----------------------------------------- **/
/** -------------------------------------------------------------------------------------- **/
- /**
- * Gets the test suite tests
- *
- * @return the test suite tests
- */
- public static TestSuite getSuite()
- {
- return new TestSuite(TopicTest.class);
- }
-
- /**
- * Run the test suite.
- *
- * @param args Any command line arguments specified to this class.
- */
- public static void main(String args[])
- {
- junit.textui.TestRunner.run(getSuite());
- }
-
+ @Override
public void tearDown() throws Exception
{
if (!isBroker08())
@@ -117,56 +97,17 @@ public class TopicTest extends AbstractX
/**
* Initialize standard actors
*/
- public void init()
+ public void init() throws Exception
{
if (!isBroker08())
{
setTestClientSystemProperty(ClientProperties.MAX_PREFETCH_PROP_NAME, "1");
// lookup test queue
- try
- {
- _topic = (Topic) getInitialContext().lookup(TOPICNAME);
- }
- catch (Exception e)
- {
- fail("cannot lookup test topic " + e.getMessage());
- }
- // lookup connection factory
- try
- {
- _topicFactory = (XATopicConnectionFactory) getConnectionFactory();
- }
- catch (Exception e)
- {
- fail("enable to lookup connection factory ");
- }
- // create standard connection
- try
- {
- _topicConnection = getNewTopicXAConnection();
- }
- catch (JMSException e)
- {
- fail("cannot create queue connection: " + e.getMessage());
- }
- // create standard session
- try
- {
- _session = _topicConnection.createXATopicSession();
- }
- catch (JMSException e)
- {
- fail("cannot create queue session: " + e.getMessage());
- }
- // create a standard session
- try
- {
- _nonXASession = _topicConnection.createTopicSession(true, Session.AUTO_ACKNOWLEDGE);
- }
- catch (JMSException e)
- {
- _logger.error("Error creating topic session", e);
- }
+ _topicFactory = (XATopicConnectionFactory) getConnectionFactory();
+ _topicConnection = getNewTopicXAConnection();
+ _session = _topicConnection.createXATopicSession();
+ _topic = _session.createTopic(getTestQueueName());
+ _nonXASession = _topicConnection.createTopicSession(true, Session.AUTO_ACKNOWLEDGE);
init(_session, _topic);
}
}
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java?rev=1780600&r1=1780599&r2=1780600&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/utils/FailoverBaseCase.java Fri Jan 27 18:09:21 2017
@@ -20,9 +20,13 @@
*/
package org.apache.qpid.test.utils;
+import java.util.ArrayList;
+import java.util.List;
import java.util.concurrent.CountDownLatch;
+import javax.jms.Connection;
import javax.jms.ConnectionFactory;
+import javax.jms.IllegalStateException;
import javax.jms.JMSException;
import javax.naming.NamingException;
@@ -43,9 +47,10 @@ public class FailoverBaseCase extends Qp
protected int _port;
protected int _alternativePort;
private ConnectionFactory _connectionFactory;
+ private final List<Connection> _connections = new ArrayList<>();
@Override
- protected void setUp() throws Exception
+ public void setUp() throws Exception
{
super.setUp();
_failoverComplete = new CountDownLatch(1);
@@ -60,6 +65,28 @@ public class FailoverBaseCase extends Qp
setTestSystemProperty("test.port", String.valueOf(_port));
}
+ @Override
+ protected void tearDown() throws Exception
+ {
+ try
+ {
+ for(Connection c : _connections)
+ {
+ try
+ {
+ c.close();
+ }
+ catch (JMSException e)
+ {
+ }
+ }
+ }
+ finally
+ {
+ super.tearDown();
+ }
+ }
+
/**
* We are using failover factories
*
@@ -87,7 +114,9 @@ public class FailoverBaseCase extends Qp
@Override
public javax.jms.Connection getConnection() throws JMSException, NamingException
{
- return getConnectionFactory().createConnection(GUEST_USERNAME, GUEST_PASSWORD);
+ final Connection connection = getConnectionFactory().createConnection(GUEST_USERNAME, GUEST_PASSWORD);
+ _connections.add(connection);
+ return connection;
}
public void failDefaultBroker()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org