mirror of https://github.com/apache/activemq.git
https://issues.apache.org/activemq/browse/AMQ-2702 - introducing activemq-spring module
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@935952 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
bb0aed0425
commit
76de7c05e6
|
@ -35,7 +35,6 @@
|
||||||
javax.transaction*;resolution:=optional,
|
javax.transaction*;resolution:=optional,
|
||||||
org.apache.activemq.ra*;resolution:=optional,
|
org.apache.activemq.ra*;resolution:=optional,
|
||||||
org.apache.geronimo.transaction.manager*;resolution:=optional,
|
org.apache.geronimo.transaction.manager*;resolution:=optional,
|
||||||
org.springframework*;resolution:=optional,
|
|
||||||
*
|
*
|
||||||
</activemq.osgi.import.pkg>
|
</activemq.osgi.import.pkg>
|
||||||
<activemq.osgi.export>
|
<activemq.osgi.export>
|
||||||
|
@ -79,10 +78,6 @@
|
||||||
<groupId>commons-pool</groupId>
|
<groupId>commons-pool</groupId>
|
||||||
<artifactId>commons-pool</artifactId>
|
<artifactId>commons-pool</artifactId>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework</groupId>
|
|
||||||
<artifactId>spring-beans</artifactId>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>${pom.groupId}</groupId>
|
<groupId>${pom.groupId}</groupId>
|
||||||
<artifactId>activemq-core</artifactId>
|
<artifactId>activemq-core</artifactId>
|
||||||
|
@ -94,26 +89,11 @@
|
||||||
<artifactId>junit</artifactId>
|
<artifactId>junit</artifactId>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
|
||||||
<groupId>org.springframework</groupId>
|
|
||||||
<artifactId>spring-jms</artifactId>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.xbean</groupId>
|
|
||||||
<artifactId>xbean-spring</artifactId>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>log4j</groupId>
|
<groupId>log4j</groupId>
|
||||||
<artifactId>log4j</artifactId>
|
<artifactId>log4j</artifactId>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.derby</groupId>
|
|
||||||
<artifactId>derby</artifactId>
|
|
||||||
<scope>test</scope>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -0,0 +1,113 @@
|
||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<!--
|
||||||
|
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.
|
||||||
|
-->
|
||||||
|
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
|
||||||
|
|
||||||
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
|
<parent>
|
||||||
|
<groupId>org.apache.activemq</groupId>
|
||||||
|
<artifactId>activemq-parent</artifactId>
|
||||||
|
<version>5.4-SNAPSHOT</version>
|
||||||
|
</parent>
|
||||||
|
|
||||||
|
<artifactId>activemq-spring</artifactId>
|
||||||
|
<packaging>bundle</packaging>
|
||||||
|
<name>ActiveMQ :: Spring</name>
|
||||||
|
<description>ActiveMQ Spring Integration</description>
|
||||||
|
|
||||||
|
<properties>
|
||||||
|
<activemq.osgi.import.pkg>
|
||||||
|
javax.transaction*;resolution:=optional,
|
||||||
|
org.apache.geronimo.transaction.manager*;resolution:=optional,
|
||||||
|
org.springframework*;resolution:=optional,
|
||||||
|
*
|
||||||
|
</activemq.osgi.import.pkg>
|
||||||
|
<activemq.osgi.export>
|
||||||
|
org.apache.activemq.pool*;version=${project.version};-noimport:=;-split-package:=merge-last,
|
||||||
|
org.apache.activemq.xbean*;version=${project.version};-noimport:=true;-split-package:=merge-last
|
||||||
|
</activemq.osgi.export>
|
||||||
|
</properties>
|
||||||
|
|
||||||
|
<dependencies>
|
||||||
|
|
||||||
|
<!-- =============================== -->
|
||||||
|
<!-- Required Dependencies -->
|
||||||
|
<!-- =============================== -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>commons-logging</groupId>
|
||||||
|
<artifactId>commons-logging-api</artifactId>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>${pom.groupId}</groupId>
|
||||||
|
<artifactId>activemq-core</artifactId>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>${pom.groupId}</groupId>
|
||||||
|
<artifactId>activemq-pool</artifactId>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.apache.geronimo.components</groupId>
|
||||||
|
<artifactId>geronimo-transaction</artifactId>
|
||||||
|
<optional>true</optional>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.apache.geronimo.specs</groupId>
|
||||||
|
<artifactId>geronimo-jta_1.0.1B_spec</artifactId>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.apache.geronimo.specs</groupId>
|
||||||
|
<artifactId>geronimo-annotation_1.0_spec</artifactId>
|
||||||
|
<optional>true</optional>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>commons-pool</groupId>
|
||||||
|
<artifactId>commons-pool</artifactId>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.springframework</groupId>
|
||||||
|
<artifactId>spring-beans</artifactId>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>${pom.groupId}</groupId>
|
||||||
|
<artifactId>activemq-core</artifactId>
|
||||||
|
<type>test-jar</type>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>junit</groupId>
|
||||||
|
<artifactId>junit</artifactId>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.springframework</groupId>
|
||||||
|
<artifactId>spring-jms</artifactId>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.apache.xbean</groupId>
|
||||||
|
<artifactId>xbean-spring</artifactId>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>log4j</groupId>
|
||||||
|
<artifactId>log4j</artifactId>
|
||||||
|
<scope>test</scope>
|
||||||
|
</dependency>
|
||||||
|
</dependencies>
|
||||||
|
|
||||||
|
</project>
|
|
@ -20,9 +20,11 @@ import javax.annotation.PostConstruct;
|
||||||
import javax.annotation.PreDestroy;
|
import javax.annotation.PreDestroy;
|
||||||
import javax.jms.ConnectionFactory;
|
import javax.jms.ConnectionFactory;
|
||||||
import javax.transaction.TransactionManager;
|
import javax.transaction.TransactionManager;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
import org.apache.commons.pool.ObjectPoolFactory;
|
import org.apache.commons.pool.ObjectPoolFactory;
|
||||||
|
import org.springframework.beans.factory.FactoryBean;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Simple factory bean used to create a jencks connection pool.
|
* Simple factory bean used to create a jencks connection pool.
|
||||||
|
@ -43,7 +45,7 @@ import org.apache.commons.pool.ObjectPoolFactory;
|
||||||
*
|
*
|
||||||
* @org.apache.xbean.XBean
|
* @org.apache.xbean.XBean
|
||||||
*/
|
*/
|
||||||
public class PooledConnectionFactoryBean {
|
public class PooledConnectionFactoryBean implements FactoryBean {
|
||||||
|
|
||||||
private static final Log LOGGER = LogFactory.getLog(PooledConnectionFactoryBean.class);
|
private static final Log LOGGER = LogFactory.getLog(PooledConnectionFactoryBean.class);
|
||||||
|
|
||||||
|
@ -169,4 +171,17 @@ public class PooledConnectionFactoryBean {
|
||||||
pooledConnectionFactory = null;
|
pooledConnectionFactory = null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// FactoryBean methods
|
||||||
|
public Object getObject() throws Exception {
|
||||||
|
return pooledConnectionFactory;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Class getObjectType() {
|
||||||
|
return ConnectionFactory.class;
|
||||||
|
}
|
||||||
|
|
||||||
|
public boolean isSingleton() {
|
||||||
|
return true;
|
||||||
|
}
|
||||||
}
|
}
|
|
@ -86,7 +86,7 @@ public class PooledBrokerFactoryBean implements FactoryBean, InitializingBean, D
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
public Class<BrokerService> getObjectType() {
|
public Class getObjectType() {
|
||||||
return BrokerService.class;
|
return BrokerService.class;
|
||||||
}
|
}
|
||||||
|
|
1
pom.xml
1
pom.xml
|
@ -142,6 +142,7 @@
|
||||||
<module>activemq-ra</module>
|
<module>activemq-ra</module>
|
||||||
<module>activemq-rar</module>
|
<module>activemq-rar</module>
|
||||||
<module>activemq-run</module>
|
<module>activemq-run</module>
|
||||||
|
<module>activemq-spring</module>
|
||||||
<module>activemq-tooling</module>
|
<module>activemq-tooling</module>
|
||||||
<module>activemq-web</module>
|
<module>activemq-web</module>
|
||||||
<module>activemq-web-demo</module>
|
<module>activemq-web-demo</module>
|
||||||
|
|
Loading…
Reference in New Issue