Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

package refactor 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@359601 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2005-12-28 19:10:15 +00:00
parent 68c8c3c867
commit 57ca31fbd3
61 changed files with 194 additions and 193 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
assembly/maven.xml
View File

@ -111,7 +111,7 @@
<ant:jar destfile="${maven.dist.bin.assembly.dir}/bin/run.jar" basedir="${maven.build.dir}/classes"> <ant:jar destfile="${maven.dist.bin.assembly.dir}/bin/run.jar" basedir="${maven.build.dir}/classes">
<ant:include name="org/activemq/broker/Main*.class"/> <ant:include name="org/activemq/broker/Main*.class"/>
<ant:manifest> <ant:manifest>
<ant:attribute name="Main-Class" value="org.activemq.broker.Main"/> <ant:attribute name="Main-Class" value="org.apache.activemq.activemq.broker.Main"/>
</ant:manifest> </ant:manifest>
</ant:jar> </ant:jar>
<ant:copy todir="${maven.dist.bin.assembly.dir/conf}"> <ant:copy todir="${maven.dist.bin.assembly.dir/conf}">
@ -253,7 +253,7 @@
</j:if> </j:if>
<echo>Running an ActiveMQ server with $$config = ${config}</echo> <echo>Running an ActiveMQ server with $$config = ${config}</echo>
<java classname="org.activemq.broker.Main" fork="yes" maxmemory="512M"> <java classname="org.apache.activemq.activemq.broker.Main" fork="yes" maxmemory="512M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<arg value="${config}"/> <arg value="${config}"/>
<j:if test="${!empty(debug)}"> <j:if test="${!empty(debug)}">
@ -273,7 +273,7 @@
<!-- run simple server using just a URL --> <!-- run simple server using just a URL -->
<echo>Running an ActiveMQ server at $$url = ${url}</echo> <echo>Running an ActiveMQ server at $$url = ${url}</echo>
<java classname="org.activemq.broker.Main" fork="yes" maxmemory="512M"> <java classname="org.apache.activemq.activemq.broker.Main" fork="yes" maxmemory="512M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<arg value="${url}"/> <arg value="${url}"/>
@ -318,7 +318,7 @@
<jvmarg value="-Xbootclasspath/a:${OPTIT_HOME}/lib/oibcp.jar"/> <jvmarg value="-Xbootclasspath/a:${OPTIT_HOME}/lib/oibcp.jar"/>
<jvmarg value="-Xnoclassgc"/> <jvmarg value="-Xnoclassgc"/>
<arg value="-pause"/> <arg value="-pause"/>
<arg value="org.activemq.spring.Main"/> <arg value="org.apache.activemq.activemq.spring.Main"/>
<arg value="${config}"/> <arg value="${config}"/>
</java> </java>
</j:when> </j:when>
@ -335,7 +335,7 @@
<jvmarg value="-Xbootclasspath/a:${OPTIT_HOME}/lib/oibcp.jar"/> <jvmarg value="-Xbootclasspath/a:${OPTIT_HOME}/lib/oibcp.jar"/>
<jvmarg value="-Xnoclassgc"/> <jvmarg value="-Xnoclassgc"/>
<arg value="-pause"/> <arg value="-pause"/>
<arg value="org.activemq.broker.Main"/> <arg value="org.apache.activemq.activemq.broker.Main"/>
<arg value="${url}"/> <arg value="${url}"/>
<sysproperty key="derby.system.home" value="target/derby"/> <sysproperty key="derby.system.home" value="target/derby"/>
<sysproperty key="derby.storage.fileSyncTransactionLog" value="true"/> <sysproperty key="derby.storage.fileSyncTransactionLog" value="true"/>
@ -359,7 +359,7 @@
</j:if> </j:if>
<echo>Running an ActiveMQ web server with webapp = ${url}</echo> <echo>Running an ActiveMQ web server with webapp = ${url}</echo>
<java classname="org.activemq.tool.WebServer" fork="yes"> <java classname="org.apache.activemq.activemq.tool.WebServer" fork="yes">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<jvmarg value="-server"/> <jvmarg value="-server"/>
<arg value="${url}"/> <arg value="${url}"/>
@ -387,7 +387,7 @@
</j:if> </j:if>
<echo>Running consumer against server at $$url = ${url} for subject $$subject = ${subject}</echo> <echo>Running consumer against server at $$url = ${url} for subject $$subject = ${subject}</echo>
<java classname="org.activemq.tool.ConsumerTool" fork="yes" maxmemory="100M"> <java classname="org.apache.activemq.activemq.tool.ConsumerTool" fork="yes" maxmemory="100M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<jvmarg value="-server"/> <jvmarg value="-server"/>
<arg value="${url}"/> <arg value="${url}"/>
@ -422,7 +422,7 @@
<echo>Running producer against server at $$url = ${url} for subject $$subject = ${subject}</echo> <echo>Running producer against server at $$url = ${url} for subject $$subject = ${subject}</echo>
<java classname="org.activemq.tool.ProducerTool" fork="yes" maxmemory="100M"> <java classname="org.apache.activemq.activemq.tool.ProducerTool" fork="yes" maxmemory="100M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<jvmarg value="-server"/> <jvmarg value="-server"/>
<arg value="${url}"/> <arg value="${url}"/>
@ -451,7 +451,7 @@
</j:if> </j:if>
<echo>Running producer using subject $$subject = ${subject}</echo> <echo>Running producer using subject $$subject = ${subject}</echo>
<java classname="org.activemq.demo.SimpleProducer" fork="yes"> <java classname="org.apache.activemq.activemq.demo.SimpleProducer" fork="yes">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<jvmarg value="-server"/> <jvmarg value="-server"/>
<arg value="${subject}"/> <arg value="${subject}"/>
@ -471,7 +471,7 @@
</j:if> </j:if>
<echo>Running consumer using subject $$subject = ${subject}</echo> <echo>Running consumer using subject $$subject = ${subject}</echo>
<java classname="org.activemq.demo.SimpleConsumer" fork="yes"> <java classname="org.apache.activemq.activemq.demo.SimpleConsumer" fork="yes">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<jvmarg value="-server"/> <jvmarg value="-server"/>
<arg value="${subject}"/> <arg value="${subject}"/>
@ -499,7 +499,7 @@
</j:if> </j:if>
<echo>Running topic consumer against server at $$url = ${url} for subject $$subject = ${subject} with $$topic = ${topic}</echo> <echo>Running topic consumer against server at $$url = ${url} for subject $$subject = ${subject} with $$topic = ${topic}</echo>
<java classname="org.activemq.benchmark.Consumer" fork="yes" maxmemory="100M"> <java classname="org.apache.activemq.activemq.benchmark.Consumer" fork="yes" maxmemory="100M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<j:if test="${empty(ignoreServer)}"> <j:if test="${empty(ignoreServer)}">
<jvmarg value="-server"/> <jvmarg value="-server"/>
@ -535,7 +535,7 @@
</j:if> </j:if>
<echo>Running topic producer against server at $$url = ${url} for subject $$subject = ${subject} with $$topic = ${topic} $$messageSize = ${messageSize}</echo> <echo>Running topic producer against server at $$url = ${url} for subject $$subject = ${subject} with $$topic = ${topic} $$messageSize = ${messageSize}</echo>
<java classname="org.activemq.benchmark.Producer" fork="yes"> <java classname="org.apache.activemq.activemq.benchmark.Producer" fork="yes">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<j:if test="${empty(ignoreServer)}"> <j:if test="${empty(ignoreServer)}">
<jvmarg value="-server"/> <jvmarg value="-server"/>
@ -570,7 +570,7 @@
</j:if> </j:if>
<echo>Running topic producer against server at $$url = ${url} for subject $$subject = ${subject} with $$topic = ${topic}</echo> <echo>Running topic producer against server at $$url = ${url} for subject $$subject = ${subject} with $$topic = ${topic}</echo>
<java classname="org.activemq.benchmark.ProducerConsumer" fork="yes" maxmemory="100M"> <java classname="org.apache.activemq.activemq.benchmark.ProducerConsumer" fork="yes" maxmemory="100M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<j:if test="${empty(ignoreServer)}"> <j:if test="${empty(ignoreServer)}">
<jvmarg value="-server"/> <jvmarg value="-server"/>
@ -619,7 +619,7 @@
</j:if> </j:if>
<echo>Running ActiveMQ Journal Benchmark</echo> <echo>Running ActiveMQ Journal Benchmark</echo>
<j:set var="mainClass" value="org.activemq.journal.impl.JournalPerfTool"/> <j:set var="mainClass" value="org.apache.activemq.activemq.journal.impl.JournalPerfTool"/>
<j:if test="${profile=='true'}"> <j:if test="${profile=='true'}">
<j:set var="mainClass" value="intuitive.audit.Audit"/> <j:set var="mainClass" value="intuitive.audit.Audit"/>
</j:if> </j:if>
@ -631,7 +631,7 @@
<jvmarg value="-Xnoclassgc"/> <jvmarg value="-Xnoclassgc"/>
<classpath path="${OPTIT_HOME}/lib/optit.jar"/> <classpath path="${OPTIT_HOME}/lib/optit.jar"/>
<arg value="-pause"/> <arg value="-pause"/>
<arg value="org.activemq.journal.impl.JournalPerfTool"/> <arg value="org.apache.activemq.activemq.journal.impl.JournalPerfTool"/>
</j:if> </j:if>
<j:elseif test="${empty(ignoreServer)}"> <j:elseif test="${empty(ignoreServer)}">
<jvmarg value="-server"/> <jvmarg value="-server"/>
@ -689,7 +689,7 @@
</j:if> </j:if>
<echo>Running HOWL Journal Benchmark</echo> <echo>Running HOWL Journal Benchmark</echo>
<java classname="org.activemq.journal.howl.JournalPerfTool" fork="no" maxmemory="100M"> <java classname="org.apache.activemq.activemq.journal.howl.JournalPerfTool" fork="no" maxmemory="100M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<j:if test="${empty(ignoreServer)}"> <j:if test="${empty(ignoreServer)}">
<jvmarg value="-server"/> <jvmarg value="-server"/>
@ -723,7 +723,7 @@
<goal name="test-create-temp-queues" prereqs="setclasspath, test:compile" <goal name="test-create-temp-queues" prereqs="setclasspath, test:compile"
description="Tests the creation of lots of temporary queues"> description="Tests the creation of lots of temporary queues">
<java classname="org.activemq.usecases.CreateLotsOfTemporaryQueuesTest" fork="yes" maxmemory="10M"> <java classname="org.apache.activemq.activemq.usecases.CreateLotsOfTemporaryQueuesTest" fork="yes" maxmemory="10M">
<classpath refid="test.classpath"/> <classpath refid="test.classpath"/>
<arg value="${count}"/> <arg value="${count}"/>
</java> </java>

3
assembly/project.properties
View File

@ -18,5 +18,6 @@ http://dist.codehaus.org,\
http://cvs.apache.org/repository,\ http://cvs.apache.org/repository,\
http://www.openejb.org/maven http://www.openejb.org/maven
maven.jar.mainclass = org.activemq.broker.Main maven.jar.mainclass = org.apache.activemq.activemq.broker.Main
maven.eclipse.classpath.include=src/test/resources

8
assembly/project.xml
View File

@ -284,8 +284,8 @@
<build> <build>
<nagEmailAddress>dev@activemq.codehaus.org</nagEmailAddress> <nagEmailAddress>dev@activemq.codehaus.org</nagEmailAddress>
<sourceDirectory>src/java</sourceDirectory> <sourceDirectory>src/main/java</sourceDirectory>
<unitTestSourceDirectory>src/test</unitTestSourceDirectory> <unitTestSourceDirectory>src/test/java</unitTestSourceDirectory>
<integrationUnitTestSourceDirectory/> <integrationUnitTestSourceDirectory/>
<aspectSourceDirectory/> <aspectSourceDirectory/>
@ -293,7 +293,7 @@
<unitTest> <unitTest>
<resources> <resources>
<resource> <resource>
<directory>src/test</directory> <directory>src/test/resources</directory>
<includes> <includes>
<include>**/*.properties</include> <include>**/*.properties</include>
<include>**/*.xml</include> <include>**/*.xml</include>
@ -324,7 +324,7 @@
<resources> <resources>
<resource> <resource>
<directory>src/resources</directory> <directory>src/main/resources</directory>
<includes> <includes>
<include>**/*</include> <include>**/*</include>
</includes> </includes>

2
assembly/src/release/conf/log4j.properties
View File

@ -2,7 +2,7 @@
# The logging properties used during tests.. # The logging properties used during tests..
# #
log4j.rootLogger=INFO, stdout log4j.rootLogger=INFO, stdout
log4j.logger.org.activemq.spring=WARN log4j.logger.org.apache.activemq.activemq.spring=WARN
log4j.logger.org.springframework=WARN log4j.logger.org.springframework=WARN
log4j.logger.org.xbean.spring=WARN log4j.logger.org.xbean.spring=WARN

6
assembly/src/release/example/conf/activemq-stomp.xml
View File

@ -23,11 +23,11 @@
<!-- Choose one of the following three configurationss to work with mysql-ds--> <!-- Choose one of the following three configurationss to work with mysql-ds-->
<!-- <!--
<jdbcPersistence dataSourceRef="mysql-ds" <jdbcPersistence dataSourceRef="mysql-ds"
adapterClass="org.activemq.store.jdbc.adapter.BytesJDBCAdaptor"/> adapterClass="org.apache.activemq.activemq.store.jdbc.adapter.BytesJDBCAdaptor"/>
<jdbcPersistence dataSourceRef="mysql-ds" <jdbcPersistence dataSourceRef="mysql-ds"
adapterClass="org.activemq.store.jdbc.adapter.BlobJDBCAdaptor"/> adapterClass="org.apache.activemq.activemq.store.jdbc.adapter.BlobJDBCAdaptor"/>
<jdbcPersistence dataSourceRef="mysql-ds" <jdbcPersistence dataSourceRef="mysql-ds"
adapterClass="org.activemq.store.jdbc.adapter.StreamJDBCAdaptor"/> adapterClass="org.apache.activemq.activemq.store.jdbc.adapter.StreamJDBCAdaptor"/>
--> -->
</journalPersistence> </journalPersistence>
</cachePersistence> </cachePersistence>

4
assembly/src/release/example/conf/log4j.properties
View File

@ -18,5 +18,5 @@ log4j.appender.logfile.append=true
# #
# You can change logger levels here. # You can change logger levels here.
# #
log4j.logger.org.activemq=INFO log4j.logger.org.apache.activemq.activemq=INFO
log4j.logger.org.activemq.spring=WARN log4j.logger.org.apache.activemq.activemq.spring=WARN

2
assembly/src/release/example/conf/web.xml
View File

@ -18,7 +18,7 @@
</context-param> </context-param>
<listener> <listener>
<listener-class>org.activemq.web.</listener-class> <listener-class>org.apache.activemq.activemq.web.</listener-class>
</listener> </listener>
</web-app> </web-app>

6
assembly/src/release/example/src/ToolSupport.java
View File

@ -15,9 +15,9 @@
* limitations under the License. * limitations under the License.
*/ */
import org.activemq.ActiveMQConnection; import org.apache.activemq.activemq.ActiveMQConnection;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.util.IndentPrinter; import org.apache.activemq.activemq.util.IndentPrinter;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;

2
assembly/src/sample-conf/journal-example.xml
View File

@ -29,7 +29,7 @@
</constructor-arg> </constructor-arg>
<constructor-arg index="3"> <constructor-arg index="3">
<bean id="myTaskRunnerFactory" class="org.activemq.thread.TaskRunnerFactory"/> <bean id="myTaskRunnerFactory" class="org.apache.activemq.activemq.thread.TaskRunnerFactory"/>
</constructor-arg> </constructor-arg>
</amq:journalPersistenceAdapter> </amq:journalPersistenceAdapter>
</amq:persistenceAdapter> </amq:persistenceAdapter>

4
assembly/src/test/log4j.properties
View File

@ -3,8 +3,8 @@
# #
log4j.rootLogger=INFO, out log4j.rootLogger=INFO, out
log4j.logger.org.activemq.spring=WARN log4j.logger.org.apache.activemq.activemq.spring=WARN
log4j.logger.org.activemq=INFO log4j.logger.org.apache.activemq.activemq=INFO
# CONSOLE appender not used by default # CONSOLE appender not used by default
log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout=org.apache.log4j.ConsoleAppender

6
assembly/src/test/org/activemq/benchmark/BenchmarkSupport.java
View File

@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.benchmark; package org.apache.activemq.activemq.benchmark;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.util.IdGenerator; import org.apache.activemq.activemq.util.IdGenerator;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;

2
assembly/src/test/org/activemq/benchmark/Consumer.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.benchmark; package org.apache.activemq.activemq.benchmark;
import javax.jms.Destination; import javax.jms.Destination;
import javax.jms.JMSException; import javax.jms.JMSException;

2
assembly/src/test/org/activemq/benchmark/Producer.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.benchmark; package org.apache.activemq.activemq.benchmark;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;
import javax.jms.Destination; import javax.jms.Destination;

2
assembly/src/test/org/activemq/benchmark/ProducerConsumer.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.benchmark; package org.apache.activemq.activemq.benchmark;
/** /**

8
assembly/src/test/org/activemq/config/BrokerXmlConfigFromJNDITest.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.config; package org.apache.activemq.activemq.config;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; import org.apache.activemq.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
import javax.naming.InitialContext; import javax.naming.InitialContext;
import javax.naming.Context; import javax.naming.Context;
@ -38,7 +38,7 @@ public class BrokerXmlConfigFromJNDITest extends JmsTopicSendReceiveWithTwoConne
// we could put these properties into a jndi.properties // we could put these properties into a jndi.properties
// on the classpath instead // on the classpath instead
Hashtable properties = new Hashtable(); Hashtable properties = new Hashtable();
properties.put("java.naming.factory.initial", "org.activemq.jndi.ActiveMQInitialContextFactory"); properties.put("java.naming.factory.initial", "org.apache.activemq.activemq.jndi.ActiveMQInitialContextFactory");
// configure the embedded broker using an XML config file // configure the embedded broker using an XML config file
// which is either a URL or a resource on the classpath // which is either a URL or a resource on the classpath

6
assembly/src/test/org/activemq/config/BrokerXmlConfigTest.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.config; package org.apache.activemq.activemq.config;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; import org.apache.activemq.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
import java.net.URI; import java.net.URI;

32
assembly/src/test/org/activemq/config/ConfigTest.java
View File

@ -14,23 +14,23 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.config; package org.apache.activemq.activemq.config;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.broker.TransportConnector; import org.apache.activemq.activemq.broker.TransportConnector;
import org.activemq.broker.region.policy.*; import org.apache.activemq.activemq.broker.region.policy.*;
import org.activemq.xbean.BrokerFactoryBean; import org.apache.activemq.activemq.xbean.BrokerFactoryBean;
import org.activemq.transport.activeio.ActiveIOTransportServer; import org.apache.activemq.activemq.transport.activeio.ActiveIOTransportServer;
import org.activemq.transport.tcp.TcpTransportServer; import org.apache.activemq.activemq.transport.tcp.TcpTransportServer;
import org.activemq.command.ActiveMQTopic; import org.apache.activemq.activemq.command.ActiveMQTopic;
import org.activemq.openwire.OpenWireFormat; import org.apache.activemq.activemq.openwire.OpenWireFormat;
import org.activemq.store.PersistenceAdapter; import org.apache.activemq.activemq.store.PersistenceAdapter;
import org.activemq.store.PersistenceAdapterFactory; import org.apache.activemq.activemq.store.PersistenceAdapterFactory;
import org.activemq.store.DefaultPersistenceAdapterFactory; import org.apache.activemq.activemq.store.DefaultPersistenceAdapterFactory;
import org.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.activemq.activemq.store.memory.MemoryPersistenceAdapter;
import org.activemq.store.jdbc.JDBCPersistenceAdapter; import org.apache.activemq.activemq.store.jdbc.JDBCPersistenceAdapter;
import org.activemq.store.journal.JournalPersistenceAdapter; import org.apache.activemq.activemq.store.journal.JournalPersistenceAdapter;
import org.activemq.memory.UsageManager; import org.apache.activemq.activemq.memory.UsageManager;
import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.FileSystemResource; import org.springframework.core.io.FileSystemResource;
import org.springframework.core.io.Resource; import org.springframework.core.io.Resource;

6
assembly/src/test/org/activemq/config/example.xml
View File

@ -68,7 +68,7 @@
</amq:memoryManager> </amq:memoryManager>
<amq:persistenceFactory> <amq:persistenceFactory>
<bean id="myPersistenceFactory" class="org.activemq.store.DefaultPersistenceAdapterFactory"> <bean id="myPersistenceFactory" class="org.apache.activemq.activemq.store.DefaultPersistenceAdapterFactory">
<property name="journalLogFileSize" value="32768" /> <property name="journalLogFileSize" value="32768" />
<property name="journalLogFiles" value="4" /> <property name="journalLogFiles" value="4" />
<property name="useJournal" value="true" /> <property name="useJournal" value="true" />
@ -82,7 +82,7 @@
</amq:broker> </amq:broker>
<!-- testing normal Spring stuff inside the same config file --> <!-- testing normal Spring stuff inside the same config file -->
<bean id="myTransportServer" class="org.activemq.transport.activeio.ActiveIOTransportServer"> <bean id="myTransportServer" class="org.apache.activemq.activemq.transport.activeio.ActiveIOTransportServer">
<constructor-arg index="0"> <constructor-arg index="0">
<bean id="brokerURI " class="java.net.URI"> <bean id="brokerURI " class="java.net.URI">
<constructor-arg index="0"> <constructor-arg index="0">
@ -97,7 +97,7 @@
<property name="stopTimeout" value="5000"/> <property name="stopTimeout" value="5000"/>
<property name="wireFormatFactory"> <property name="wireFormatFactory">
<bean id="myWireFormatFactory" class="org.activemq.openwire.OpenWireFormatFactory"> <bean id="myWireFormatFactory" class="org.apache.activemq.activemq.openwire.OpenWireFormatFactory">
<property name="stackTraceEnabled" value="false"/> <property name="stackTraceEnabled" value="false"/>
<property name="tcpNoDelayEnabled" value="true"/> <property name="tcpNoDelayEnabled" value="true"/>
<property name="cacheEnabled" value="false" /> <property name="cacheEnabled" value="false" />

6
assembly/src/test/org/activemq/config/spring-test.xml
View File

@ -2,11 +2,11 @@
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans> <beans>
<bean id="wireFormat" class="org.activemq.io.impl.DefaultWireFormat"/> <bean id="wireFormat" class="org.apache.activemq.activemq.io.impl.DefaultWireFormat"/>
<bean id="transport" factory-method="newInstance" class="org.activemq.transport.TransportServerChannelProvider"> <bean id="transport" factory-method="newInstance" class="org.apache.activemq.activemq.transport.TransportServerChannelProvider">
<constructor-arg index="0"> <constructor-arg index="0">
<bean class="org.activemq.io.impl.DefaultWireFormat"/> <bean class="org.apache.activemq.activemq.io.impl.DefaultWireFormat"/>
<!--- <!---
<ref bean="wireFormat"/> <ref bean="wireFormat"/>
--> -->

2
assembly/src/test/org/activemq/transport/QueueClusterTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.transport; package org.apache.activemq.activemq.transport;

20
assembly/src/test/org/activemq/transport/TopicClusterTest.java
View File

@ -15,18 +15,18 @@
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.transport; package org.apache.activemq.activemq.transport;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.broker.TransportConnector; import org.apache.activemq.activemq.broker.TransportConnector;
import org.activemq.command.ActiveMQQueue; import org.apache.activemq.activemq.command.ActiveMQQueue;
import org.activemq.command.ActiveMQTextMessage; import org.apache.activemq.activemq.command.ActiveMQTextMessage;
import org.activemq.command.ActiveMQTopic; import org.apache.activemq.activemq.command.ActiveMQTopic;
import org.activemq.network.NetworkConnector; import org.apache.activemq.activemq.network.NetworkConnector;
import org.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgent; import org.apache.activemq.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgent;
import org.activemq.util.ServiceStopper; import org.apache.activemq.activemq.util.ServiceStopper;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;

4
assembly/src/test/org/activemq/usecases/ChangeSentMessageTest.java
View File

@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import java.util.HashMap; import java.util.HashMap;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;
@ -24,7 +24,7 @@ import javax.jms.MessageProducer;
import javax.jms.ObjectMessage; import javax.jms.ObjectMessage;
import javax.jms.Session; import javax.jms.Session;
import org.activemq.test.TestSupport; import org.apache.activemq.activemq.test.TestSupport;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

4
assembly/src/test/org/activemq/usecases/ChangeSessionDeliveryModeTest.java
View File

@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import java.util.HashMap; import java.util.HashMap;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;
@ -28,7 +28,7 @@ import javax.jms.MessageProducer;
import javax.jms.ObjectMessage; import javax.jms.ObjectMessage;
import javax.jms.Session; import javax.jms.Session;
import org.activemq.test.TestSupport; import org.apache.activemq.activemq.test.TestSupport;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

6
assembly/src/test/org/activemq/usecases/CompositeConsumeTest.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.command.ActiveMQTopic; import org.apache.activemq.activemq.command.ActiveMQTopic;
import org.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; import org.apache.activemq.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
import javax.jms.Destination; import javax.jms.Destination;
import javax.jms.Message; import javax.jms.Message;

8
assembly/src/test/org/activemq/usecases/CompositePublishTest.java
View File

@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.command.ActiveMQTopic; import org.apache.activemq.activemq.command.ActiveMQTopic;
import org.activemq.test.JmsSendReceiveTestSupport; import org.apache.activemq.activemq.test.JmsSendReceiveTestSupport;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;

2
assembly/src/test/org/activemq/usecases/ConsumeQueuePrefetchTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.JMSException; import javax.jms.JMSException;

4
assembly/src/test/org/activemq/usecases/ConsumeTopicPrefetchTest.java
View File

@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.JMSException; import javax.jms.JMSException;
import javax.jms.Message; import javax.jms.Message;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import org.activemq.ActiveMQConnection; import org.apache.activemq.activemq.ActiveMQConnection;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

4
assembly/src/test/org/activemq/usecases/CreateLotsOfTemporaryQueuesTest.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.EmbeddedBrokerTestSupport; import org.apache.activemq.activemq.EmbeddedBrokerTestSupport;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Session; import javax.jms.Session;

6
assembly/src/test/org/activemq/usecases/CreateTemporaryQueueBeforeStartTest.java
View File

@ -15,11 +15,11 @@
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Queue; import javax.jms.Queue;

6
assembly/src/test/org/activemq/usecases/DeadLetterTest.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.TestSupport; import org.apache.activemq.activemq.TestSupport;
import org.activemq.command.ActiveMQDestination; import org.apache.activemq.activemq.command.ActiveMQDestination;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;

4
assembly/src/test/org/activemq/usecases/DurableConsumerCloseAndReconnectTest.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.test.TestSupport; import org.apache.activemq.activemq.test.TestSupport;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;

8
assembly/src/test/org/activemq/usecases/DurableSubscriptionTestSupport.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;
@ -28,9 +28,9 @@ import javax.jms.TextMessage;
import javax.jms.Topic; import javax.jms.Topic;
import javax.jms.TopicSubscriber; import javax.jms.TopicSubscriber;
import org.activemq.TestSupport; import org.apache.activemq.activemq.TestSupport;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.store.PersistenceAdapter; import org.apache.activemq.activemq.store.PersistenceAdapter;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

4
assembly/src/test/org/activemq/usecases/ExceptionListenerTest.java
View File

@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
* *
**/ **/
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.ExceptionListener; import javax.jms.ExceptionListener;
import javax.jms.JMSException; import javax.jms.JMSException;
@ -39,7 +39,7 @@ public class ExceptionListenerTest extends TestCase implements ExceptionListener
/* TODO not sure yet if this is a valid test /* TODO not sure yet if this is a valid test
System.setProperty("activemq.persistenceAdapter", System.setProperty("activemq.persistenceAdapter",
"org.activemq.store.vm.VMPersistenceAdapter"); "org.apache.activemq.activemq.store.vm.VMPersistenceAdapter");
// configuration of container and all protocolls // configuration of container and all protocolls
BrokerContainerImpl container = new BrokerContainerImpl container = new
BrokerContainerImpl("DefaultBroker"); BrokerContainerImpl("DefaultBroker");

8
assembly/src/test/org/activemq/usecases/JDBCDurableSubscriptionTest.java
View File

@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import org.activemq.store.DefaultPersistenceAdapterFactory; import org.apache.activemq.activemq.store.DefaultPersistenceAdapterFactory;
import org.activemq.store.PersistenceAdapter; import org.apache.activemq.activemq.store.PersistenceAdapter;
import org.activemq.store.jdbc.JDBCPersistenceAdapter; import org.apache.activemq.activemq.store.jdbc.JDBCPersistenceAdapter;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

6
assembly/src/test/org/activemq/usecases/JournalDurableSubscriptionTest.java
View File

@ -15,13 +15,13 @@
* limitations under the License. * limitations under the License.
* *
**/ **/
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import java.io.File; import java.io.File;
import java.io.IOException; import java.io.IOException;
import org.activemq.store.DefaultPersistenceAdapterFactory; import org.apache.activemq.activemq.store.DefaultPersistenceAdapterFactory;
import org.activemq.store.PersistenceAdapter; import org.apache.activemq.activemq.store.PersistenceAdapter;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

2
assembly/src/test/org/activemq/usecases/ProducerConsumerTestSupport.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;

2
assembly/src/test/org/activemq/usecases/PublishOnDurableTopicConsumedMessageTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

2
assembly/src/test/org/activemq/usecases/PublishOnQueueConsumedMessageTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

8
assembly/src/test/org/activemq/usecases/PublishOnQueueConsumedMessageUsingActivemqXMLTest.java
View File

@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.xbean.BrokerFactoryBean; import org.apache.activemq.activemq.xbean.BrokerFactoryBean;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource; import org.springframework.core.io.Resource;

2
assembly/src/test/org/activemq/usecases/PublishOnTemporaryQueueConsumedMessageTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;

6
assembly/src/test/org/activemq/usecases/PublishOnTopicConsumedMessageTest.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; import org.apache.activemq.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
import javax.jms.Destination; import javax.jms.Destination;
import javax.jms.JMSException; import javax.jms.JMSException;
@ -34,7 +34,7 @@ public class PublishOnTopicConsumedMessageTest extends JmsTopicSendReceiveWithTw
// lets resend the message somewhere else // lets resend the message somewhere else
try { try {
Message msgCopy = (Message)((org.activemq.command.Message)message).copy(); Message msgCopy = (Message)((org.apache.activemq.activemq.command.Message)message).copy();
replyProducer.send(msgCopy); replyProducer.send(msgCopy);
//System.out.println("Sending reply: " + message); //System.out.println("Sending reply: " + message);

8
assembly/src/test/org/activemq/usecases/PublishOnTopicConsumerMessageUsingActivemqXMLTest.java
View File

@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.xbean.BrokerFactoryBean; import org.apache.activemq.activemq.xbean.BrokerFactoryBean;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.Resource; import org.springframework.core.io.Resource;
import java.io.File; import java.io.File;

2
assembly/src/test/org/activemq/usecases/QueueConsumerCloseAndReconnectTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

4
assembly/src/test/org/activemq/usecases/QueueDuplicatesTest.java
View File

@ -15,7 +15,7 @@
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import java.text.DateFormat; import java.text.DateFormat;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Date; import java.util.Date;
@ -35,7 +35,7 @@ import javax.jms.MessageProducer;
import javax.jms.Session; import javax.jms.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import junit.framework.TestCase; import junit.framework.TestCase;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
public class QueueDuplicatesTest extends TestCase { public class QueueDuplicatesTest extends TestCase {
private static DateFormat formatter = new SimpleDateFormat("HH:mm:ss SSS"); private static DateFormat formatter = new SimpleDateFormat("HH:mm:ss SSS");

2
assembly/src/test/org/activemq/usecases/QueueRedeliverTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
/** /**

16
assembly/src/test/org/activemq/usecases/ReliableReconnectTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import java.util.HashMap; import java.util.HashMap;
import java.net.URI; import java.net.URI;
import javax.jms.Connection; import javax.jms.Connection;
@ -33,13 +33,13 @@ import javax.jms.QueueSession;
import javax.jms.Session; import javax.jms.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.jms.Topic; import javax.jms.Topic;
import org.activemq.ActiveMQConnection; import org.apache.activemq.activemq.ActiveMQConnection;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.broker.BrokerFactory; import org.apache.activemq.activemq.broker.BrokerFactory;
import org.activemq.broker.Broker; import org.apache.activemq.activemq.broker.Broker;
import org.activemq.test.TestSupport; import org.apache.activemq.activemq.test.TestSupport;
import org.activemq.util.IdGenerator; import org.apache.activemq.activemq.util.IdGenerator;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger; import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;

12
assembly/src/test/org/activemq/usecases/StartAndStopBrokerTest.java
View File

@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import junit.framework.TestCase; import junit.framework.TestCase;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.broker.BrokerFactory; import org.apache.activemq.activemq.broker.BrokerFactory;
import org.activemq.broker.TransportConnector; import org.apache.activemq.activemq.broker.TransportConnector;
import javax.jms.JMSException; import javax.jms.JMSException;
import java.net.URI; import java.net.URI;
@ -34,7 +34,7 @@ public class StartAndStopBrokerTest extends TestCase {
// This systemproperty is used if we dont want to // This systemproperty is used if we dont want to
// have persistence messages as a default // have persistence messages as a default
System.setProperty("activemq.persistenceAdapter", System.setProperty("activemq.persistenceAdapter",
"org.activemq.store.vm.VMPersistenceAdapter"); "org.apache.activemq.activemq.store.vm.VMPersistenceAdapter");
// configuration of container and all protocolls // configuration of container and all protocolls
BrokerService broker = createBroker(); BrokerService broker = createBroker();

6
assembly/src/test/org/activemq/usecases/SubscribeClosePublishThenConsumeTest.java
View File

@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.test.TestSupport; import org.apache.activemq.activemq.test.TestSupport;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;

10
assembly/src/test/org/activemq/usecases/TestSupport.java
View File

@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.command.ActiveMQMessage; import org.apache.activemq.activemq.command.ActiveMQMessage;
import org.activemq.command.ActiveMQQueue; import org.apache.activemq.activemq.command.ActiveMQQueue;
import org.activemq.command.ActiveMQTopic; import org.apache.activemq.activemq.command.ActiveMQTopic;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;

6
assembly/src/test/org/activemq/usecases/TopicRedeliverTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;
@ -26,8 +26,8 @@ import javax.jms.Session;
import javax.jms.TextMessage; import javax.jms.TextMessage;
import javax.jms.Topic; import javax.jms.Topic;
import org.activemq.test.TestSupport; import org.apache.activemq.activemq.test.TestSupport;
import org.activemq.util.IdGenerator; import org.apache.activemq.activemq.util.IdGenerator;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

8
assembly/src/test/org/activemq/usecases/TransactionRollbackOrderTest.java
View File

@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch; import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
import junit.framework.TestCase; import junit.framework.TestCase;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.command.ActiveMQQueue; import org.apache.activemq.activemq.command.ActiveMQQueue;
import org.activemq.command.ActiveMQTopic; import org.apache.activemq.activemq.command.ActiveMQTopic;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;

6
assembly/src/test/org/activemq/usecases/TransactionTest.java
View File

@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import junit.framework.TestCase; import junit.framework.TestCase;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.command.ActiveMQQueue; import org.apache.activemq.activemq.command.ActiveMQQueue;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Destination; import javax.jms.Destination;

2
assembly/src/test/org/activemq/usecases/TransientQueueRedeliverTest.java
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;

4
assembly/src/test/org/activemq/usecases/TwoBrokerQueueSendReceiveTest.java
View File

@ -15,9 +15,9 @@
* limitations under the License. * limitations under the License.
* *
**/ **/
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
/** /**
* @version $Revision: 1.1.1.1 $ * @version $Revision: 1.1.1.1 $

12
assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveTest.java
View File

@ -14,16 +14,16 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.JMSException; import javax.jms.JMSException;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.broker.TransportConnector; import org.apache.activemq.activemq.broker.TransportConnector;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.xbean.BrokerFactoryBean; import org.apache.activemq.activemq.xbean.BrokerFactoryBean;
import org.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; import org.apache.activemq.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.ClassPathResource;
/** /**

4
assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingHttpTest.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import javax.jms.JMSException; import javax.jms.JMSException;

8
assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java
View File

@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.store.memory.MemoryPersistenceAdapter; import org.apache.activemq.activemq.store.memory.MemoryPersistenceAdapter;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import javax.jms.JMSException; import javax.jms.JMSException;

10
assembly/src/test/org/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java
View File

@ -14,14 +14,14 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import javax.jms.JMSException; import javax.jms.JMSException;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import org.activemq.xbean.BrokerFactoryBean; import org.apache.activemq.activemq.xbean.BrokerFactoryBean;
import org.activemq.broker.BrokerService; import org.apache.activemq.activemq.broker.BrokerService;
import org.activemq.broker.TransportConnector; import org.apache.activemq.activemq.broker.TransportConnector;
import org.springframework.core.io.ClassPathResource; import org.springframework.core.io.ClassPathResource;
import java.io.IOException; import java.io.IOException;

4
assembly/src/test/org/activemq/usecases/TwoMulticastDiscoveryBrokerTopicSendReceiveTest.java
View File

@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
package org.activemq.usecases; package org.apache.activemq.activemq.usecases;
import org.activemq.ActiveMQConnectionFactory; import org.apache.activemq.activemq.ActiveMQConnectionFactory;
import javax.jms.JMSException; import javax.jms.JMSException;

2
assembly/src/test/org/activemq/usecases/receiver-activecluster.xml
View File

@ -8,7 +8,7 @@
</connector> </connector>
<discoveryAgent> <discoveryAgent>
<activeClusterDiscovery uri="multicast://224.1.2.3:2123" subject="org.activemq.discover"/> <activeClusterDiscovery uri="multicast://224.1.2.3:2123" subject="org.apache.activemq.activemq.discover"/>
</discoveryAgent> </discoveryAgent>
<discoveryNetworkConnector/> <discoveryNetworkConnector/>

2
assembly/src/test/org/activemq/usecases/sender-activecluster.xml
View File

@ -8,7 +8,7 @@
</connector> </connector>
<discoveryAgent> <discoveryAgent>
<activeClusterDiscovery uri="multicast://224.1.2.3:2123" subject="org.activemq.discover"/> <activeClusterDiscovery uri="multicast://224.1.2.3:2123" subject="org.apache.activemq.activemq.discover"/>
</discoveryAgent> </discoveryAgent>
<discoveryNetworkConnector/> <discoveryNetworkConnector/>