activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject git commit: fix and reinstate skipped xa jms/jdbc test that sanity tests xa recovery - remove the load variant that was also skipped
Date Wed, 05 Mar 2014 16:09:09 GMT
Repository: activemq
Updated Branches:
  refs/heads/trunk cfe099d1c -> 9c4621da8


fix and reinstate skipped xa jms/jdbc test that sanity tests xa recovery - remove the load
variant that was also skipped


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/9c4621da
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/9c4621da
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/9c4621da

Branch: refs/heads/trunk
Commit: 9c4621da8c37f15917f1e189f51ba04c084c2788
Parents: cfe099d
Author: gtully <gary.tully@gmail.com>
Authored: Wed Mar 5 16:03:14 2014 +0000
Committer: gtully <gary.tully@gmail.com>
Committed: Wed Mar 5 16:03:14 2014 +0000

----------------------------------------------------------------------
 activemq-camel/pom.xml                          |   7 +
 .../activemq/camel/JmsJdbcXALoadTest.java       | 143 -------------------
 .../apache/activemq/camel/JmsJdbcXATest.java    |   1 -
 .../org/apache/activemq/camel/jmsXajdbc.xml     |   2 +-
 4 files changed, 8 insertions(+), 145 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/9c4621da/activemq-camel/pom.xml
----------------------------------------------------------------------
diff --git a/activemq-camel/pom.xml b/activemq-camel/pom.xml
index 6d27cca..4c80570 100755
--- a/activemq-camel/pom.xml
+++ b/activemq-camel/pom.xml
@@ -127,6 +127,13 @@
       <scope>test</scope>
     </dependency>
     <dependency>
+      <groupId>org.apache.openejb</groupId>
+      <artifactId>openejb-core</artifactId>
+      <version>3.1</version>
+      <optional>true</optional>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
       <groupId>org.objectweb.howl</groupId>
       <artifactId>howl</artifactId>
       <version>1.0.1-1</version>

http://git-wip-us.apache.org/repos/asf/activemq/blob/9c4621da/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXALoadTest.java
----------------------------------------------------------------------
diff --git a/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXALoadTest.java
b/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXALoadTest.java
deleted file mode 100644
index 00ea6e8..0000000
--- a/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXALoadTest.java
+++ /dev/null
@@ -1,143 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.camel;
-
-import java.sql.ResultSet;
-import java.sql.SQLException;
-
-import javax.jms.Connection;
-import javax.jms.MessageProducer;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-
-import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.command.ActiveMQQueue;
-import org.apache.activemq.util.Wait;
-import org.apache.camel.test.spring.CamelSpringTestSupport;
-import org.apache.commons.dbcp.BasicDataSource;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.springframework.context.support.AbstractXmlApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-@Ignore("Test hangs")
-public class JmsJdbcXALoadTest extends CamelSpringTestSupport {
-
-    BrokerService broker = null;
-    int messageCount;
-
-    public java.sql.Connection initDb() throws Exception {
-        String createStatement = "CREATE TABLE SCP_INPUT_MESSAGES (" + "id int NOT NULL GENERATED
ALWAYS AS IDENTITY, " + "messageId varchar(96) NOT NULL, "
-            + "messageCorrelationId varchar(96) NOT NULL, " + "messageContent varchar(2048)
NOT NULL, " + "PRIMARY KEY (id) )";
-
-        java.sql.Connection conn = getJDBCConnection();
-        try {
-            conn.createStatement().execute(createStatement);
-        } catch (SQLException alreadyExists) {
-            log.info("ex on create tables", alreadyExists);
-        }
-
-        try {
-            conn.createStatement().execute("DELETE FROM SCP_INPUT_MESSAGES");
-        } catch (SQLException ex) {
-            log.info("ex on create delete all", ex);
-        }
-
-        return conn;
-    }
-
-    private java.sql.Connection getJDBCConnection() throws Exception {
-        BasicDataSource dataSource = getMandatoryBean(BasicDataSource.class, "managedDataSourceWithRecovery");
-        return dataSource.getConnection();
-    }
-
-    private int dumpDb(java.sql.Connection jdbcConn) throws Exception {
-        int count = 0;
-        ResultSet resultSet = jdbcConn.createStatement().executeQuery("SELECT * FROM SCP_INPUT_MESSAGES");
-        while (resultSet.next()) {
-            count++;
-        }
-        log.info(count + " messages");
-        return count;
-    }
-
-    @SuppressWarnings("unused")
-    @Test
-    public void testRecoveryCommit() throws Exception {
-        java.sql.Connection jdbcConn = initDb();
-        final int count = 1000;
-
-        sendJMSMessageToKickOffRoute(count);
-
-        final java.sql.Connection freshConnection = getJDBCConnection();
-        assertTrue("did not get replay", Wait.waitFor(new Wait.Condition() {
-            @Override
-            public boolean isSatisified() throws Exception {
-                return count == dumpDb(freshConnection);
-            }
-        }, 20 * 60 * 1000));
-        assertEquals("still one message in db", count, dumpDb(freshConnection));
-    }
-
-    private void sendJMSMessageToKickOffRoute(int count) throws Exception {
-        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://testXA");
-        factory.setWatchTopicAdvisories(false);
-        Connection connection = factory.createConnection();
-        connection.start();
-        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        MessageProducer producer = session.createProducer(new ActiveMQQueue("scp_transacted"));
-        for (int i = 0; i < count; i++) {
-            TextMessage message = session.createTextMessage("Some Text, messageCount:" +
messageCount++);
-            message.setJMSCorrelationID("pleaseCorrelate");
-            producer.send(message);
-        }
-        connection.close();
-    }
-
-    private BrokerService createBroker(boolean deleteAllMessages) throws Exception {
-        BrokerService brokerService = new BrokerService();
-        brokerService.setDeleteAllMessagesOnStartup(deleteAllMessages);
-        brokerService.setBrokerName("testXA");
-        brokerService.setAdvisorySupport(false);
-        brokerService.setUseJmx(false);
-        brokerService.setDataDirectory("target/data");
-        brokerService.addConnector("tcp://0.0.0.0:61616");
-        return brokerService;
-    }
-
-    @Override
-    protected AbstractXmlApplicationContext createApplicationContext() {
-
-        deleteDirectory("target/data/howl");
-
-        // make broker available to recovery processing on app context start
-        try {
-            broker = createBroker(true);
-            broker.start();
-        } catch (Exception e) {
-            throw new RuntimeException("Failed to start broker", e);
-        }
-
-        return new ClassPathXmlApplicationContext("org/apache/activemq/camel/jmsXajdbc.xml");
-    }
-
-    @Override
-    public void tearDown() throws Exception {
-        super.tearDown();
-    }
-}

http://git-wip-us.apache.org/repos/asf/activemq/blob/9c4621da/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXATest.java
----------------------------------------------------------------------
diff --git a/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXATest.java b/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXATest.java
index 236e0a1..8481ca6 100644
--- a/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXATest.java
+++ b/activemq-camel/src/test/java/org/apache/activemq/camel/JmsJdbcXATest.java
@@ -45,7 +45,6 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
 /**
  *  shows broker 'once only delivery' and recovery with XA
  */
-@Ignore("Test hangs")
 public class JmsJdbcXATest extends CamelSpringTestSupport {
     private static final Logger LOG = LoggerFactory.getLogger(JmsJdbcXATest.class);
     BrokerService broker = null;

http://git-wip-us.apache.org/repos/asf/activemq/blob/9c4621da/activemq-camel/src/test/resources/org/apache/activemq/camel/jmsXajdbc.xml
----------------------------------------------------------------------
diff --git a/activemq-camel/src/test/resources/org/apache/activemq/camel/jmsXajdbc.xml b/activemq-camel/src/test/resources/org/apache/activemq/camel/jmsXajdbc.xml
index 0fa1afb..1c58a14 100644
--- a/activemq-camel/src/test/resources/org/apache/activemq/camel/jmsXajdbc.xml
+++ b/activemq-camel/src/test/resources/org/apache/activemq/camel/jmsXajdbc.xml
@@ -40,7 +40,7 @@
         <property name="transactionLog" ref="transactionLog"/>
     </bean>
 
-    <bean id="activemqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
+    <bean id="activemqConnectionFactory" class="org.apache.activemq.ActiveMQXAConnectionFactory">
         <property name="brokerURL" value="tcp://localhost:61616?jms.dispatchAsync=false"/>
     </bean>
 


Mime
View raw message