You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2005/12/28 18:28:57 UTC
svn commit: r359567 [12/13] - in /incubator/activemq/trunk/activemq-core: ./
src/gram/java/org/activemq/openwire/tool/ src/gram/script/
src/main/grammar/ src/main/java/org/activemq/
src/main/java/org/activemq/advisory/ src/main/java/org/activemq/broker...
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueReceiver.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueReceiver.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueReceiver.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueReceiver.java Wed Dec 28 09:24:02 2005
@@ -22,7 +22,7 @@
* with SimpleQueueSender. Specify a queue name on the command
* line when you run the program.
*/
-package org.activemq.demo;
+package org.apache.activemq.demo;
import javax.jms.JMSException;
import javax.jms.Message;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueSender.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueSender.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueSender.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleQueueSender.java Wed Dec 28 09:24:02 2005
@@ -24,7 +24,7 @@
* program. By default, the program sends one message. Specify
* a number after the queue name to send that number of messages.
*/
-package org.activemq.demo;
+package org.apache.activemq.demo;
// START SNIPPET: demo
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/BadDummyPolicyConfigTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/BadDummyPolicyConfigTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/BadDummyPolicyConfigTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/BadDummyPolicyConfigTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.filter;
+package org.apache.activemq.filter;
import junit.framework.TestCase;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationMapTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationMapTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationMapTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationMapTest.java Wed Dec 28 09:24:02 2005
@@ -15,11 +15,13 @@
* limitations under the License.
*/
-package org.activemq.filter;
+package org.apache.activemq.filter;
import junit.framework.TestCase;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQTopic;
+
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.filter.DestinationMap;
import java.util.ArrayList;
import java.util.Arrays;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationPathTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationPathTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationPathTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DestinationPathTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.filter;
+package org.apache.activemq.filter;
+
+import org.apache.activemq.filter.DestinationPath;
import junit.framework.TestCase;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicy.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicy.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicy.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicy.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.filter;
+package org.apache.activemq.filter;
import java.util.List;
+
+import org.apache.activemq.filter.DestinationMap;
/**
* Represents a destination based policy
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyEntry.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.filter;
+package org.apache.activemq.filter;
+
+import org.apache.activemq.filter.DestinationMapEntry;
/**
*
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/filter/DummyPolicyTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.filter;
+package org.apache.activemq.filter;
-import org.activemq.SpringTestSupport;
-import org.activemq.command.ActiveMQTopic;
+import org.apache.activemq.SpringTestSupport;
+import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
@@ -39,7 +39,7 @@
protected AbstractApplicationContext createApplicationContext() {
// TODO Auto-generated method stub
- return new ClassPathXmlApplicationContext("org/activemq/filter/dummyPolicy.xml");
+ return new ClassPathXmlApplicationContext("org/apache/activemq/filter/dummyPolicy.xml");
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/ActiveMQInitialContextFactoryTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/ActiveMQInitialContextFactoryTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/ActiveMQInitialContextFactoryTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/ActiveMQInitialContextFactoryTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.jndi;
+package org.apache.activemq.jndi;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
import javax.naming.*;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/CustomConnectionFactoryNameTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/CustomConnectionFactoryNameTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/CustomConnectionFactoryNameTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/CustomConnectionFactoryNameTest.java Wed Dec 28 09:24:02 2005
@@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.jndi;
+package org.apache.activemq.jndi;
import javax.naming.NamingException;
-import org.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.ActiveMQConnectionFactory;
/**
* Test case for AMQ-141
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/DestinationNameWithSlashTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/DestinationNameWithSlashTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/DestinationNameWithSlashTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/DestinationNameWithSlashTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.jndi;
+package org.apache.activemq.jndi;
/**
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/InitialContextTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/InitialContextTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/InitialContextTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/InitialContextTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.jndi;
+package org.apache.activemq.jndi;
import junit.framework.TestCase;
-import org.activemq.ActiveMQConnectionFactory;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
import javax.naming.InitialContext;
import javax.naming.Context;
@@ -45,7 +46,7 @@
public void testUsingStandardJNDIKeys() throws Exception {
Properties properties = new Properties();
- properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.activemq.jndi.ActiveMQInitialContextFactory");
+ properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
String expected = "tcp://localhost:65432";
properties.put(Context.PROVIDER_URL, expected);
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/JNDITestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/JNDITestSupport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/JNDITestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/jndi/JNDITestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.jndi;
+package org.apache.activemq.jndi;
import junit.framework.TestCase;
@@ -28,7 +28,8 @@
import javax.jms.JMSException;
import java.util.Hashtable;
-import org.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.jndi.ActiveMQInitialContextFactory;
/**
* @version $Revision: 1.3 $
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundaryStatisticTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundaryStatisticTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundaryStatisticTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundaryStatisticTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.management;
+package org.apache.activemq.management;
+
+import org.apache.activemq.management.BoundaryStatisticImpl;
public class BoundaryStatisticTest extends StatisticTestSupport {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/BoundedRangeStatisticTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.management;
+package org.apache.activemq.management;
+
+import org.apache.activemq.management.BoundedRangeStatisticImpl;
/**
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/CountStatisticTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/CountStatisticTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/CountStatisticTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/CountStatisticTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.management;
+package org.apache.activemq.management;
+
+import org.apache.activemq.management.CountStatisticImpl;
public class CountStatisticTest extends StatisticTestSupport {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/RangeStatisticTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/RangeStatisticTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/RangeStatisticTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/RangeStatisticTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.management;
+package org.apache.activemq.management;
+
+import org.apache.activemq.management.RangeStatisticImpl;
public class RangeStatisticTest extends StatisticTestSupport {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/StatisticTestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/StatisticTestSupport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/StatisticTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/StatisticTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.management;
+package org.apache.activemq.management;
+
+import org.apache.activemq.management.StatisticImpl;
import junit.framework.TestCase;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/TimeStatisticTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/TimeStatisticTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/TimeStatisticTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/management/TimeStatisticTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.management;
+package org.apache.activemq.management;
+
+import org.apache.activemq.management.TimeStatisticImpl;
public class TimeStatisticTest extends StatisticTestSupport {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/DummyMessage.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.memory.buffer;
+package org.apache.activemq.memory.buffer;
-import org.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQMessage;
/**
* A message implementation which is useful for testing as we can spoof its size
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.memory.buffer;
+package org.apache.activemq.memory.buffer;
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.memory.buffer.MessageBuffer;
-import org.activemq.memory.buffer.MessageQueue;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.memory.buffer.MessageBuffer;
+import org.apache.activemq.memory.buffer.MessageQueue;
import junit.framework.TestCase;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.memory.buffer;
+package org.apache.activemq.memory.buffer;
-import org.activemq.memory.buffer.MessageBuffer;
-import org.activemq.memory.buffer.OrderBasedMessageBuffer;
+import org.apache.activemq.memory.buffer.MessageBuffer;
+import org.apache.activemq.memory.buffer.OrderBasedMessageBuffer;
/**
*
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.memory.buffer;
+package org.apache.activemq.memory.buffer;
-import org.activemq.memory.buffer.MessageBuffer;
-import org.activemq.memory.buffer.SizeBasedMessageBuffer;
+import org.apache.activemq.memory.buffer.MessageBuffer;
+import org.apache.activemq.memory.buffer.SizeBasedMessageBuffer;
/**
*
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/DemandForwardingBridgeTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/DemandForwardingBridgeTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/DemandForwardingBridgeTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/DemandForwardingBridgeTest.java Wed Dec 28 09:24:02 2005
@@ -14,17 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.network;
+package org.apache.activemq.network;
import javax.jms.DeliveryMode;
-import org.activemq.broker.StubConnection;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.SessionInfo;
+import org.apache.activemq.network.DemandForwardingBridge;
import junit.framework.Test;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/ForwardingBridgeTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/ForwardingBridgeTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/ForwardingBridgeTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/ForwardingBridgeTest.java Wed Dec 28 09:24:02 2005
@@ -14,17 +14,18 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.network;
+package org.apache.activemq.network;
import javax.jms.DeliveryMode;
-import org.activemq.broker.StubConnection;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.SessionInfo;
+import org.apache.activemq.network.ForwardingBridge;
import junit.framework.Test;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/NetworkTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/NetworkTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/network/NetworkTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.network;
+package org.apache.activemq.network;
import java.io.IOException;
import java.net.URI;
@@ -22,16 +22,16 @@
import java.util.ArrayList;
import java.util.Iterator;
-import org.activemq.broker.BrokerRegistry;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.BrokerTestSupport;
-import org.activemq.broker.StubConnection;
-import org.activemq.broker.TransportConnector;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.store.memory.MemoryPersistenceAdapter;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
+import org.apache.activemq.broker.BrokerRegistry;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerTestSupport;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
public class NetworkTestSupport extends BrokerTestSupport {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.network.jms;
+package org.apache.activemq.network.jms;
import java.net.URI;
import java.util.ArrayList;
@@ -22,18 +22,18 @@
import javax.jms.*;
import junit.framework.TestCase;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.broker.BrokerRegistry;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.BrokerTestSupport;
-import org.activemq.broker.StubConnection;
-import org.activemq.broker.TransportConnector;
-import org.activemq.broker.region.QueueRegion;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.store.memory.MemoryPersistenceAdapter;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerRegistry;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerTestSupport;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.broker.region.QueueRegion;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.memory.MemoryPersistenceAdapter;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
@@ -51,7 +51,7 @@
protected void setUp() throws Exception {
super.setUp();
- context = new ClassPathXmlApplicationContext("org/activemq/network/jms/queue-config.xml");
+ context = new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/queue-config.xml");
ActiveMQConnectionFactory fac = (ActiveMQConnectionFactory) context.getBean("localFactory");
localConnection = fac.createQueueConnection();
localConnection.start();
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.network.jms;
+package org.apache.activemq.network.jms;
import javax.jms.Destination;
import javax.jms.JMSException;
@@ -29,7 +29,8 @@
import javax.jms.TopicRequestor;
import javax.jms.TopicSession;
import junit.framework.TestCase;
-import org.activemq.ActiveMQConnectionFactory;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
@@ -66,7 +67,7 @@
protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("org/activemq/network/jms/topic-spring.xml");
+ return new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/topic-spring.xml");
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.network.jms;
+package org.apache.activemq.network.jms;
import org.springframework.context.support.AbstractApplicationContext;
import org.xbean.spring.context.ClassPathXmlApplicationContext;
@@ -26,7 +26,7 @@
public class TopicBridgeXBeanTest extends TopicBridgeSpringTest {
protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("org/activemq/network/jms/topic-config.xml");
+ return new ClassPathXmlApplicationContext("org/apache/activemq/network/jms/topic-config.xml");
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/BrokerInfoData.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.openwire;
+package org.apache.activemq.openwire;
-import org.activemq.command.BrokerId;
-import org.activemq.command.BrokerInfo;
+import org.apache.activemq.command.BrokerId;
+import org.apache.activemq.command.BrokerInfo;
public class BrokerInfoData extends DataFileGenerator {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/DataFileGenerator.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/DataFileGenerator.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/DataFileGenerator.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/DataFileGenerator.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.openwire;
+package org.apache.activemq.openwire;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
@@ -28,6 +28,8 @@
import java.util.ArrayList;
import java.util.Iterator;
+import org.apache.activemq.openwire.OpenWireFormat;
+
import junit.framework.Assert;
abstract public class DataFileGenerator extends Assert {
@@ -47,7 +49,7 @@
}
moduleBaseDir = basedir;
controlDir = new File(moduleBaseDir, "src/test/resources/openwire-control");
- classFileDir = new File(moduleBaseDir, "src/test/java/org/activemq/openwire");
+ classFileDir = new File(moduleBaseDir, "src/test/java/org/apache/activemq/openwire");
}
public static void main(String[] args) throws Exception {
@@ -70,7 +72,7 @@
if( file.getName().endsWith("Data.java") ) {
String cn = file.getName();
cn = cn.substring(0, cn.length() - ".java".length());
- Class clazz = DataFileGenerator.class.getClassLoader().loadClass("org.activemq.openwire."+cn);
+ Class clazz = DataFileGenerator.class.getClassLoader().loadClass("org.apache.activemq.openwire."+cn);
l.add((DataFileGenerator) clazz.newInstance());
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/ItStillMarshallsTheSameTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/ItStillMarshallsTheSameTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/ItStillMarshallsTheSameTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/ItStillMarshallsTheSameTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.openwire;
+package org.apache.activemq.openwire;
import junit.framework.TestCase;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/openwire/WireFormatInfoData.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.openwire;
+package org.apache.activemq.openwire;
-import org.activemq.command.WireFormatInfo;
+import org.apache.activemq.command.WireFormatInfo;
public class WireFormatInfoData extends DataFileGenerator {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfProducer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfProducer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfProducer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfProducer.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfRate.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfRate.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfRate.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfRate.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
/**
* @version $Revision: 1.3 $
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentQueueTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentQueueTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentQueueTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentQueueTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentTopicTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentTopicTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentTopicTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentTopicTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.Destination;
import javax.jms.JMSException;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.perf;
+package org.apache.activemq.perf;
import javax.jms.BytesMessage;
import javax.jms.Connection;
@@ -23,8 +23,9 @@
import javax.jms.JMSException;
import javax.jms.Session;
import junit.framework.TestCase;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.broker.BrokerService;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
/**
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/pool/JmsSendReceiveTwoConnectionsWithSenderUsingPoolTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/pool/JmsSendReceiveTwoConnectionsWithSenderUsingPoolTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/pool/JmsSendReceiveTwoConnectionsWithSenderUsingPoolTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/pool/JmsSendReceiveTwoConnectionsWithSenderUsingPoolTest.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.pool;
+package org.apache.activemq.pool;
-import org.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
+import org.apache.activemq.pool.PooledConnectionFactory;
+import org.apache.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest;
import javax.jms.Connection;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyConnectorTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyConnectorTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyConnectorTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyConnectorTest.java Wed Dec 28 09:24:02 2005
@@ -14,17 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.proxy;
+package org.apache.activemq.proxy;
import javax.jms.DeliveryMode;
-import org.activemq.broker.StubConnection;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.SessionInfo;
import junit.framework.Test;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyTestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyTestSupport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,20 +14,21 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.proxy;
+package org.apache.activemq.proxy;
import java.net.URI;
import java.util.ArrayList;
import java.util.Iterator;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.BrokerTestSupport;
-import org.activemq.broker.StubConnection;
-import org.activemq.broker.TransportConnector;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerTestSupport;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.proxy.ProxyConnector;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
public class ProxyTestSupport extends BrokerTestSupport {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/security/SimpleSecurityBrokerSystemTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/security/SimpleSecurityBrokerSystemTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/security/SimpleSecurityBrokerSystemTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/security/SimpleSecurityBrokerSystemTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.security;
+package org.apache.activemq.security;
import java.io.IOException;
import java.net.URL;
@@ -31,14 +31,17 @@
import junit.framework.Test;
-import org.activemq.JmsTestSupport;
-import org.activemq.broker.Broker;
-import org.activemq.broker.BrokerService;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.filter.DestinationMap;
import org.activemq.jaas.GroupPrincipal;
+import org.apache.activemq.JmsTestSupport;
+import org.apache.activemq.broker.Broker;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.filter.DestinationMap;
+import org.apache.activemq.security.JaasAuthenticationBroker;
+import org.apache.activemq.security.SimpleAuthenticationBroker;
+import org.apache.activemq.security.SimpleAuthorizationBroker;
/**
* Tests that the broker allows/fails access to destinations based on the
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorParserTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorParserTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorParserTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorParserTest.java Wed Dec 28 09:24:02 2005
@@ -14,16 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.selector;
+package org.apache.activemq.selector;
import junit.framework.TestCase;
-import org.activemq.filter.BooleanExpression;
-import org.activemq.filter.ComparisonExpression;
-import org.activemq.filter.Expression;
-import org.activemq.filter.LogicExpression;
-import org.activemq.filter.PropertyExpression;
-import org.activemq.filter.XPathExpression;
+import org.apache.activemq.filter.BooleanExpression;
+import org.apache.activemq.filter.ComparisonExpression;
+import org.apache.activemq.filter.Expression;
+import org.apache.activemq.filter.LogicExpression;
+import org.apache.activemq.filter.PropertyExpression;
+import org.apache.activemq.filter.XPathExpression;
+import org.apache.activemq.selector.SelectorParser;
/**
* @version $Revision: 1.2 $
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/selector/SelectorTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.selector;
+package org.apache.activemq.selector;
import javax.jms.InvalidSelectorException;
import javax.jms.JMSException;
@@ -22,11 +22,12 @@
import junit.framework.TestCase;
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ActiveMQTextMessage;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.filter.BooleanExpression;
-import org.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.filter.BooleanExpression;
+import org.apache.activemq.filter.MessageEvaluationContext;
+import org.apache.activemq.selector.SelectorParser;
/**
* @version $Revision: 1.7 $
@@ -321,7 +322,7 @@
BooleanExpression selector = new SelectorParser().parse(text);
assertTrue("Created a valid selector", selector != null);
MessageEvaluationContext context = new MessageEvaluationContext();
- context.setMessageReference((org.activemq.command.Message)message);
+ context.setMessageReference((org.apache.activemq.command.Message)message);
boolean value = selector.matches(context);
assertEquals("Selector for: " + text, expected, value);
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Consumer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Consumer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Consumer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Consumer.java Wed Dec 28 09:24:02 2005
@@ -24,7 +24,7 @@
* program. By default, the program sends one message. Specify
* a number after the queue name to send that number of messages.
*/
-package org.activemq.simple;
+package org.apache.activemq.simple;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
@@ -34,8 +34,8 @@
import javax.jms.MessageConsumer;
import javax.jms.Session;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.command.ActiveMQQueue;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQQueue;
public class Consumer {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Producer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Producer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Producer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/simple/Producer.java Wed Dec 28 09:24:02 2005
@@ -23,7 +23,7 @@
* program. By default, the program sends one message. Specify
* a number after the queue name to send that number of messages.
*/
-package org.activemq.simple;
+package org.apache.activemq.simple;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
@@ -33,8 +33,8 @@
import javax.jms.Session;
import javax.jms.TextMessage;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.command.ActiveMQQueue;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQQueue;
public class Producer {
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/ConsumerBean.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/ConsumerBean.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/ConsumerBean.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/ConsumerBean.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.spring;
+package org.apache.activemq.spring;
import javax.jms.Message;
import javax.jms.MessageListener;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringConsumer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringConsumer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringConsumer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringConsumer.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.activemq.spring;
+package org.apache.activemq.spring;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringProducer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringProducer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringProducer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringProducer.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.spring;
+package org.apache.activemq.spring;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/SpringTest.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.activemq.spring;
+package org.apache.activemq.spring;
import java.util.Iterator;
import java.util.List;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/streams/JMSInputStreamTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/streams/JMSInputStreamTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/streams/JMSInputStreamTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/streams/JMSInputStreamTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.streams;
+package org.apache.activemq.streams;
import java.io.DataInputStream;
import java.io.DataOutputStream;
@@ -22,10 +22,10 @@
import junit.framework.Test;
-import org.activemq.ActiveMQConnection;
-import org.activemq.JmsTestSupport;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.JmsTestSupport;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsResourceProvider.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsResourceProvider.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsResourceProvider.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsResourceProvider.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsResourceProvider.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsResourceProvider.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsResourceProvider.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
import javax.jms.Connection;
import javax.jms.ConnectionConsumer;
@@ -28,7 +28,7 @@
import javax.jms.DeliveryMode;
import javax.jms.Topic;
-import org.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.ActiveMQConnectionFactory;
/**
* @version $Revision: 1.4 $
@@ -46,7 +46,7 @@
/**
* Creates a connection factory.
*
- * @see org.activemq.test.JmsResourceProvider#createConnectionFactory()
+ * @see org.apache.activemq.test.JmsResourceProvider#createConnectionFactory()
*/
public ConnectionFactory createConnectionFactory() throws Exception {
return new ActiveMQConnectionFactory(serverUri);
@@ -55,7 +55,7 @@
/**
* Creates a connection.
*
- * @see org.activemq.test.JmsResourceProvider#createConnection(javax.jms.ConnectionFactory)
+ * @see org.apache.activemq.test.JmsResourceProvider#createConnection(javax.jms.ConnectionFactory)
*/
public Connection createConnection(ConnectionFactory cf) throws JMSException {
Connection connection = cf.createConnection();
@@ -66,14 +66,14 @@
}
/**
- * @see org.activemq.test.JmsResourceProvider#createSession(javax.jms.Connection)
+ * @see org.apache.activemq.test.JmsResourceProvider#createSession(javax.jms.Connection)
*/
public Session createSession(Connection conn) throws JMSException {
return conn.createSession(transacted, ackMode);
}
/**
- * @see org.activemq.test.JmsResourceProvider#createConsumer(javax.jms.Session,
+ * @see org.apache.activemq.test.JmsResourceProvider#createConsumer(javax.jms.Session,
* javax.jms.Destination)
*/
public MessageConsumer createConsumer(Session session,
@@ -97,7 +97,7 @@
/**
* Creates a producer.
*
- * @see org.activemq.test.JmsResourceProvider#createProducer(javax.jms.Session,
+ * @see org.apache.activemq.test.JmsResourceProvider#createProducer(javax.jms.Session,
* javax.jms.Destination)
*/
public MessageProducer createProducer(Session session,
@@ -110,7 +110,7 @@
/**
* Creates a destination, which can either a topic or a queue.
*
- * @see org.activemq.test.JmsResourceProvider#createDestination(javax.jms.Session,
+ * @see org.apache.activemq.test.JmsResourceProvider#createDestination(javax.jms.Session,
* java.lang.String)
*/
public Destination createDestination(Session session, String name)
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsSendReceiveTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsSendReceiveTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsSendReceiveTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.broker.BrokerService;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerService;
import javax.jms.JMSException;
import javax.jms.Message;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.broker.BrokerService;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerService;
/**
* @version $Revision: 1.3 $
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Session;
-import org.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.ActiveMQConnectionFactory;
/**
* @version $Revision: 1.3 $
@@ -116,7 +116,7 @@
/**
* Creates an ActiveMQConnectionFactory.
*
- * @see org.activemq.test.TestSupport#createConnectionFactory()
+ * @see org.apache.activemq.test.TestSupport#createConnectionFactory()
*/
protected ActiveMQConnectionFactory createConnectionFactory() throws Exception {
return new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/TestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/TestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/TestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/TestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/TestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/test/TestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/TestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,15 +14,16 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test;
+package org.apache.activemq.test;
import junit.framework.TestCase;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
import javax.jms.Connection;
import javax.jms.Destination;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/DummyMessageQuery.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/DummyMessageQuery.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/DummyMessageQuery.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/DummyMessageQuery.java Wed Dec 28 09:24:02 2005
@@ -14,12 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test.retroactive;
+package org.apache.activemq.test.retroactive;
-import org.activemq.broker.region.policy.MessageQuery;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQTextMessage;
-import org.activemq.command.Message;
+import org.apache.activemq.broker.region.policy.MessageQuery;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.activemq.command.Message;
import javax.jms.MessageListener;
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithDestinationBasedBufferTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithDestinationBasedBufferTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithDestinationBasedBufferTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithDestinationBasedBufferTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test.retroactive;
+package org.apache.activemq.test.retroactive;
/**
*
@@ -22,6 +22,6 @@
*/
public class RetroactiveConsumerTestWithDestinationBasedBufferTest extends RetroactiveConsumerTestWithSimpleMessageListTest {
protected String getBrokerXml() {
- return "org/activemq/test/retroactive/activemq-fixed-destination-buffer.xml";
+ return "org/apache/activemq/test/retroactive/activemq-fixed-destination-buffer.xml";
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithSimpleMessageListTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithSimpleMessageListTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithSimpleMessageListTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithSimpleMessageListTest.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test.retroactive;
+package org.apache.activemq.test.retroactive;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.EmbeddedBrokerTestSupport;
-import org.activemq.broker.BrokerService;
-import org.activemq.util.MessageList;
-import org.activemq.xbean.BrokerFactoryBean;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.EmbeddedBrokerTestSupport;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.util.MessageList;
+import org.apache.activemq.xbean.BrokerFactoryBean;
import org.springframework.core.io.ClassPathResource;
import javax.jms.Connection;
@@ -103,7 +103,7 @@
}
protected String getBrokerXml() {
- return "org/activemq/test/retroactive/activemq-fixed-buffer.xml";
+ return "org/apache/activemq/test/retroactive/activemq-fixed-buffer.xml";
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithTimePolicyTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithTimePolicyTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithTimePolicyTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerTestWithTimePolicyTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test.retroactive;
+package org.apache.activemq.test.retroactive;
/**
*
@@ -22,6 +22,6 @@
*/
public class RetroactiveConsumerTestWithTimePolicyTest extends RetroactiveConsumerTestWithSimpleMessageListTest {
protected String getBrokerXml() {
- return "org/activemq/test/retroactive/activemq-timed-policy.xml";
+ return "org/apache/activemq/test/retroactive/activemq-timed-policy.xml";
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerWithMessageQueryTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerWithMessageQueryTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerWithMessageQueryTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerWithMessageQueryTest.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.test.retroactive;
+package org.apache.activemq.test.retroactive;
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.EmbeddedBrokerTestSupport;
-import org.activemq.broker.BrokerService;
-import org.activemq.util.MessageList;
-import org.activemq.xbean.BrokerFactoryBean;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.EmbeddedBrokerTestSupport;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.util.MessageList;
+import org.apache.activemq.xbean.BrokerFactoryBean;
import org.springframework.core.io.ClassPathResource;
import javax.jms.Connection;
@@ -101,7 +101,7 @@
}
protected String getBrokerXml() {
- return "org/activemq/test/retroactive/activemq-message-query.xml";
+ return "org/apache/activemq/test/retroactive/activemq-message-query.xml";
}
}
Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/thread/TaskRunnerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/thread/TaskRunnerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/thread/TaskRunnerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/thread/TaskRunnerTest.java Wed Dec 28 09:24:02 2005
@@ -14,7 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.thread;
+package org.apache.activemq.thread;
+
+import org.apache.activemq.thread.Task;
+import org.apache.activemq.thread.TaskRunner;
+import org.apache.activemq.thread.TaskRunnerFactory;
import junit.framework.TestCase;
import edu.emory.mathcs.backport.java.util.concurrent.BrokenBarrierException;
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TransportBrokerTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/transport/TransportBrokerTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TransportBrokerTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TransportBrokerTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/transport/TransportBrokerTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/transport/TransportBrokerTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TransportBrokerTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,17 +14,19 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.activemq.transport;
+package org.apache.activemq.transport;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Iterator;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.BrokerTest;
-import org.activemq.broker.StubConnection;
-import org.activemq.broker.TransportConnector;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerTest;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
abstract public class TransportBrokerTestSupport extends BrokerTest {