activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r359567 [11/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...
Date Wed, 28 Dec 2005 17:28:57 GMT
Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTopicCompositeSendReceiveTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueTopicCompositeSendReceiveTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTopicCompositeSendReceiveTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTopicCompositeSendReceiveTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueTopicCompositeSendReceiveTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueTopicCompositeSendReceiveTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTopicCompositeSendReceiveTest.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;
+package org.apache.activemq;
 
-import org.activemq.test.JmsTopicSendReceiveTest;
+import org.apache.activemq.test.JmsTopicSendReceiveTest;
 
 import javax.jms.DeliveryMode;
 import javax.jms.Destination;
@@ -57,7 +57,7 @@
      * Returns the consumer subject.
      *
      * @return String - consumer subject
-     * @see org.activemq.test.TestSupport#getConsumerSubject()
+     * @see org.apache.activemq.test.TestSupport#getConsumerSubject()
      */
     protected String getConsumerSubject() {
         return "FOO.BAR.HUMBUG";
@@ -67,7 +67,7 @@
      * Returns the producer subject.
      *
      * @return String - producer subject
-     * @see org.activemq.test.TestSupport#getProducerSubject()
+     * @see org.apache.activemq.test.TestSupport#getProducerSubject()
      */
     protected String getProducerSubject() {
         return "queue://FOO.BAR.HUMBUG,topic://FOO.BAR.HUMBUG2";

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTransactionTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueTransactionTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTransactionTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTransactionTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueTransactionTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueTransactionTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTransactionTest.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;
+package org.apache.activemq;
 
 import java.util.ArrayList;
 import java.util.Enumeration;
@@ -27,7 +27,7 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import org.activemq.test.JmsResourceProvider;
+import org.apache.activemq.test.JmsResourceProvider;
 
 
 /**
@@ -39,7 +39,7 @@
     
 	/**
 	 * 
-	 * @see org.activemq.JmsTransactionTestSupport#getJmsResourceProvider()
+	 * @see org.apache.activemq.JmsTransactionTestSupport#getJmsResourceProvider()
 	 */
 	protected JmsResourceProvider getJmsResourceProvider() {
         JmsResourceProvider p = new JmsResourceProvider();

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueWildcardSendReceiveTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueWildcardSendReceiveTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsQueueWildcardSendReceiveTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.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;
+package org.apache.activemq;
 
 import javax.jms.DeliveryMode;
 import javax.jms.Session;
@@ -25,8 +25,8 @@
 import javax.jms.JMSException;
 import javax.jms.MessageProducer;
 
-import org.activemq.test.JmsTopicSendReceiveTest;
-import org.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.test.JmsTopicSendReceiveTest;
 
 
 /**
@@ -54,7 +54,7 @@
      * Returns the consumer subject.
      * 
      * @return String - consumer subject
-     * @see org.activemq.test.TestSupport#getConsumerSubject()
+     * @see org.apache.activemq.test.TestSupport#getConsumerSubject()
      */
     protected String getConsumerSubject(){
         return "FOO.>";
@@ -64,7 +64,7 @@
      * Returns the producer subject.
      * 
      * @return String - producer subject
-     * @see org.activemq.test.TestSupport#getProducerSubject()
+     * @see org.apache.activemq.test.TestSupport#getProducerSubject()
      */
     protected String getProducerSubject(){
         return "FOO.BAR.HUMBUG";

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsRedeliveredTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsRedeliveredTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsRedeliveredTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsRedeliveredTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsRedeliveredTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsRedeliveredTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsRedeliveredTest.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;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.DeliveryMode;
@@ -27,6 +27,8 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 import javax.jms.Topic;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
 
 import junit.framework.Test;
 import junit.framework.TestCase;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsSendReceiveTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsSendReceiveTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsSendReceiveTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/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;
+package org.apache.activemq;
 
 import javax.jms.DeliveryMode;
 import javax.jms.Destination;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSessionRecoverTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsSessionRecoverTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSessionRecoverTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSessionRecoverTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsSessionRecoverTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsSessionRecoverTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSessionRecoverTest.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;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.DeliveryMode;
@@ -27,8 +27,9 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
 
 import junit.framework.TestCase;
 import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTempDestinationTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTempDestinationTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTempDestinationTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq;
+package org.apache.activemq;
 
 import java.util.ArrayList;
 import javax.jms.*;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
 
 import junit.framework.TestCase;
 

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.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;
+package org.apache.activemq;
 
 import java.io.IOException;
 import java.net.URI;
@@ -31,9 +31,11 @@
 import javax.jms.MessageProducer;
 import javax.jms.Session;
 
-import org.activemq.broker.BrokerFactory;
-import org.activemq.broker.BrokerService;
-import org.activemq.command.ActiveMQDestination;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.command.ActiveMQDestination;
 
 /**
  * Test cases used to test the JMS message comsumer.

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicCompositeSendReceiveTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicCompositeSendReceiveTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicCompositeSendReceiveTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicCompositeSendReceiveTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicCompositeSendReceiveTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicCompositeSendReceiveTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicCompositeSendReceiveTest.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;
+package org.apache.activemq;
 
-import org.activemq.test.JmsTopicSendReceiveTest;
+import org.apache.activemq.test.JmsTopicSendReceiveTest;
 
 import javax.jms.DeliveryMode;
 import javax.jms.Destination;
@@ -57,7 +57,7 @@
      * Returns the consumer subject.
      *
      * @return String - consumer subject
-     * @see org.activemq.test.TestSupport#getConsumerSubject()
+     * @see org.apache.activemq.test.TestSupport#getConsumerSubject()
      */
     protected String getConsumerSubject() {
         return "FOO.BAR.HUMBUG";
@@ -67,7 +67,7 @@
      * Returns the producer subject.
      *
      * @return String - producer subject
-     * @see org.activemq.test.TestSupport#getProducerSubject()
+     * @see org.apache.activemq.test.TestSupport#getProducerSubject()
      */
     protected String getProducerSubject() {
         return "FOO.BAR.HUMBUG,FOO.BAR.HUMBUG2";

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRedeliverTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicRedeliverTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRedeliverTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRedeliverTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicRedeliverTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicRedeliverTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRedeliverTest.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;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.Destination;
@@ -26,6 +26,8 @@
 import javax.jms.TextMessage;
 import javax.jms.Topic;
 
+import org.apache.activemq.ActiveMQConnection;
+
 /**
  * @version $Revision: 1.4 $
  */
@@ -90,7 +92,7 @@
      * Returns the consumer subject.
      *
      * @return String - consumer subject
-     * @see org.activemq.test.TestSupport#getConsumerSubject()
+     * @see org.apache.activemq.test.TestSupport#getConsumerSubject()
      */
     protected String getConsumerSubject() {
         return "TEST";
@@ -100,7 +102,7 @@
      * Returns the producer subject.
      *
      * @return String - producer subject
-     * @see org.activemq.test.TestSupport#getProducerSubject()
+     * @see org.apache.activemq.test.TestSupport#getProducerSubject()
      */
     protected String getProducerSubject() {
         return "TEST";

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicRequestReplyTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicRequestReplyTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicRequestReplyTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.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;
+package org.apache.activemq;
 
 import java.util.List;
 import java.util.Vector;
@@ -29,7 +29,7 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import org.activemq.test.TestSupport;
+import org.apache.activemq.test.TestSupport;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSelectorTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSelectorTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSelectorTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.DeliveryMode;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveSubscriberTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveSubscriberTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveSubscriberTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveSubscriberTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveSubscriberTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveSubscriberTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveSubscriberTest.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;
+package org.apache.activemq;
 
 import javax.jms.JMSException;
 import javax.jms.MessageConsumer;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/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;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.DeliveryMode;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java Wed Dec 28 09:24:02 2005
@@ -14,11 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.DeliveryMode;
 import javax.jms.Session;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
 
 /**
  * @version

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.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;
+package org.apache.activemq;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
 
 /**
  *

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendSameMessageTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendSameMessageTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendSameMessageTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendSameMessageTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendSameMessageTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicSendSameMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendSameMessageTest.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;
+package org.apache.activemq;
 
 import javax.jms.TextMessage;
 
-import org.activemq.JmsTopicSendReceiveWithTwoConnectionsTest;
+import org.apache.activemq.JmsTopicSendReceiveWithTwoConnectionsTest;
 
 /**
  * @version $Revision: 1.3 $

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicTransactionTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicTransactionTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicTransactionTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicTransactionTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicTransactionTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicTransactionTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicTransactionTest.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;
+package org.apache.activemq;
 
-import org.activemq.test.JmsResourceProvider;
+import org.apache.activemq.test.JmsResourceProvider;
 
 
 /**
@@ -25,7 +25,7 @@
 public class JmsTopicTransactionTest extends JmsTransactionTestSupport {
 
     /**
-     * @see org.activemq.JmsTransactionTestSupport#getJmsResourceProvider()
+     * @see org.apache.activemq.JmsTransactionTestSupport#getJmsResourceProvider()
      */
     protected JmsResourceProvider getJmsResourceProvider() {
         JmsResourceProvider p = new JmsResourceProvider();

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicWildcardSendReceiveTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicWildcardSendReceiveTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTopicWildcardSendReceiveTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.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;
+package org.apache.activemq;
 
 import javax.jms.DeliveryMode;
 import javax.jms.Session;
@@ -25,8 +25,8 @@
 import javax.jms.JMSException;
 import javax.jms.MessageProducer;
 
-import org.activemq.test.JmsTopicSendReceiveTest;
-import org.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.test.JmsTopicSendReceiveTest;
 
 
 /**

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTransactionTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTransactionTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/JmsTransactionTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq;
+package org.apache.activemq;
 
-import org.activemq.test.JmsResourceProvider;
-import org.activemq.test.TestSupport;
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQPrefetchPolicy;
+import org.apache.activemq.test.JmsResourceProvider;
+import org.apache.activemq.test.TestSupport;
 
 import javax.jms.Connection;
 import javax.jms.ConnectionFactory;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeMessageTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/LargeMessageTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeMessageTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeMessageTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/LargeMessageTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/LargeMessageTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeMessageTestSupport.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq;
+package org.apache.activemq;
 
 import javax.jms.BytesMessage;
 import javax.jms.Connection;
@@ -29,10 +29,12 @@
 import javax.jms.Session;
 import javax.jms.Topic;
 
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.util.IdGenerator;
+import org.apache.activemq.ActiveMQConnection;
+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.activemq.util.IdGenerator;
 
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
 

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/LoadTestBurnIn.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/LoadTestBurnIn.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/LoadTestBurnIn.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.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;
+package org.apache.activemq;
 
 import java.io.IOException;
 import java.net.URI;
@@ -33,10 +33,11 @@
 
 import junit.framework.Test;
 
-import org.activemq.broker.BrokerFactory;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.TransportConnector;
-import org.activemq.command.ActiveMQDestination;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.command.ActiveMQDestination;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
@@ -75,7 +76,7 @@
     
     protected BrokerService createBroker() throws Exception {
         return BrokerFactory.createBroker(new URI("broker://(tcp://localhost:0)?useJmx=true"));
-//        return BrokerFactory.createBroker(new URI("xbean:org/activemq/broker/store/loadtester.xml"));
+//        return BrokerFactory.createBroker(new URI("xbean:org/apache/activemq/broker/store/loadtester.xml"));
     }
 
     protected ConnectionFactory createConnectionFactory() throws URISyntaxException, IOException {

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageTransformationTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/MessageTransformationTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageTransformationTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageTransformationTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/MessageTransformationTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/MessageTransformationTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageTransformationTest.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq;
+package org.apache.activemq;
 
 import javax.jms.BytesMessage;
 import javax.jms.MapMessage;
@@ -29,17 +29,18 @@
 
 import junit.framework.TestCase;
 
-import org.activemq.command.ActiveMQBytesMessage;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQMapMessage;
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ActiveMQObjectMessage;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQStreamMessage;
-import org.activemq.command.ActiveMQTempQueue;
-import org.activemq.command.ActiveMQTempTopic;
-import org.activemq.command.ActiveMQTextMessage;
-import org.activemq.command.ActiveMQTopic;
+import org.apache.activemq.ActiveMQMessageTransformation;
+import org.apache.activemq.command.ActiveMQBytesMessage;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQMapMessage;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQObjectMessage;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQStreamMessage;
+import org.apache.activemq.command.ActiveMQTempQueue;
+import org.apache.activemq.command.ActiveMQTempTopic;
+import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.activemq.command.ActiveMQTopic;
 
 public class MessageTransformationTest extends TestCase {
 	

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RedeliveryPolicyTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/RedeliveryPolicyTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RedeliveryPolicyTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RedeliveryPolicyTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/RedeliveryPolicyTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/RedeliveryPolicyTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RedeliveryPolicyTest.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;
+package org.apache.activemq;
 
 import javax.jms.MessageConsumer;
 import javax.jms.MessageProducer;
@@ -23,8 +23,8 @@
 
 import junit.framework.Test;
 
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.RedeliveryPolicy;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.RedeliveryPolicy;
 
 /**
  * Test cases used to test the JMS message exclusive consumers.

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/SpringTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/SpringTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/SpringTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/SpringTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/SpringTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/SpringTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/SpringTestSupport.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq;
+package org.apache.activemq;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/TestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/TestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/TestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.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;
+package org.apache.activemq;
 
 import java.io.File;
 
@@ -26,9 +26,10 @@
 
 import junit.framework.TestCase;
 
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
+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;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/ConsumerListenerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/ConsumerListenerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/ConsumerListenerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/ConsumerListenerTest.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.advisory;
+package org.apache.activemq.advisory;
 
 import edu.emory.mathcs.backport.java.util.concurrent.ArrayBlockingQueue;
 import edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue;
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
 
-import org.activemq.EmbeddedBrokerTestSupport;
+import org.apache.activemq.EmbeddedBrokerTestSupport;
+import org.apache.activemq.advisory.ConsumerEvent;
+import org.apache.activemq.advisory.ConsumerEventSource;
+import org.apache.activemq.advisory.ConsumerListener;
 
 import javax.jms.Connection;
 import javax.jms.JMSException;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerBenchmark.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerBenchmark.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerBenchmark.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java Wed Dec 28 09:24:02 2005
@@ -14,20 +14,20 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 
 import junit.framework.Test;
 
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.SessionInfo;
 
 import edu.emory.mathcs.backport.java.util.concurrent.Semaphore;
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerRestartTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerRestartTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerRestartTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,12 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import java.io.IOException;
 import java.net.URISyntaxException;
 
-import org.activemq.store.PersistenceAdapter;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.store.PersistenceAdapter;
 
 public class BrokerRestartTestSupport extends BrokerTestSupport {
 

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,24 +14,24 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import javax.jms.DeliveryMode;
 import javax.jms.JMSException;
 
 import junit.framework.Test;
 
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.DestinationInfo;
-import org.activemq.command.LocalTransactionId;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.DestinationInfo;
+import org.apache.activemq.command.LocalTransactionId;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.SessionInfo;
 
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
 

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerTestSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerTestSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/BrokerTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.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.broker;
+package org.apache.activemq.broker;
 
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
 
@@ -29,27 +29,29 @@
 import javax.jms.DeliveryMode;
 import javax.jms.MessageNotWriteableException;
 
-import org.activemq.CombinationTestSupport;
-import org.activemq.broker.region.RegionBroker;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQTextMessage;
-import org.activemq.command.ConnectionId;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.DestinationInfo;
-import org.activemq.command.LocalTransactionId;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.MessageDispatch;
-import org.activemq.command.MessageId;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.RemoveInfo;
-import org.activemq.command.SessionInfo;
-import org.activemq.command.TransactionId;
-import org.activemq.command.TransactionInfo;
-import org.activemq.command.XATransactionId;
-import org.activemq.memory.UsageManager;
-import org.activemq.store.PersistenceAdapter;
+import org.apache.activemq.CombinationTestSupport;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.region.RegionBroker;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.activemq.command.ConnectionId;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.DestinationInfo;
+import org.apache.activemq.command.LocalTransactionId;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.MessageDispatch;
+import org.apache.activemq.command.MessageId;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.RemoveInfo;
+import org.apache.activemq.command.SessionInfo;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.command.TransactionInfo;
+import org.apache.activemq.command.XATransactionId;
+import org.apache.activemq.memory.UsageManager;
+import org.apache.activemq.store.PersistenceAdapter;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MarshallingBrokerTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/MarshallingBrokerTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MarshallingBrokerTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MarshallingBrokerTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/MarshallingBrokerTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/MarshallingBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MarshallingBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,16 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import java.io.IOException;
 
 import junit.framework.Test;
 
 import org.activeio.command.WireFormat;
-import org.activemq.command.Command;
-import org.activemq.command.Response;
-import org.activemq.openwire.OpenWireFormat;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.openwire.OpenWireFormat;
 
 /**
  * Runs against the broker but marshals all request and response commands.

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ProgressPrinter.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/ProgressPrinter.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ProgressPrinter.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ProgressPrinter.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/ProgressPrinter.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/ProgressPrinter.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ProgressPrinter.java Wed Dec 28 09:24:02 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 
 public class ProgressPrinter {

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/RecoveryBrokerTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/RecoveryBrokerTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/RecoveryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,22 +14,22 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import javax.jms.DeliveryMode;
 
 import junit.framework.Test;
 
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.Message;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ActiveMQTopic;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.LocalTransactionId;
-import org.activemq.command.MessageAck;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.LocalTransactionId;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.SessionInfo;
 
 /**
  * Used to simulate the recovery that occurs when a broker shuts down.

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/SpringTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/SpringTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/SpringTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/SpringTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/SpringTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/SpringTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/SpringTest.java Wed Dec 28 09:24:02 2005
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import java.util.Iterator;
 import java.util.List;
 
 import junit.framework.TestCase;
 
-import org.activemq.spring.SpringConsumer;
-import org.activemq.spring.SpringProducer;
+import org.apache.activemq.spring.SpringConsumer;
+import org.apache.activemq.spring.SpringProducer;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.context.support.AbstractApplicationContext;
@@ -38,7 +38,7 @@
     protected SpringProducer producer;
 
     public void testSenderWithSpringXml() throws Exception {
-        assertSenderConfig("org/activemq/broker/spring.xml");
+        assertSenderConfig("org/apache/activemq/broker/spring.xml");
     }
     /**
      * assert method that is used by all the test method to send and receive messages

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/StubConnection.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/StubConnection.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/StubConnection.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java Wed Dec 28 09:24:02 2005
@@ -14,20 +14,23 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import java.io.IOException;
 
-import org.activemq.Service;
-import org.activemq.command.Command;
-import org.activemq.command.ExceptionResponse;
-import org.activemq.command.Message;
-import org.activemq.command.Response;
-import org.activemq.command.ShutdownInfo;
-import org.activemq.thread.TaskRunnerFactory;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportListener;
-import org.activemq.util.ServiceSupport;
+import org.apache.activemq.Service;
+import org.apache.activemq.broker.AbstractConnection;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.Connection;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.ExceptionResponse;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.command.ShutdownInfo;
+import org.apache.activemq.thread.TaskRunnerFactory;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportListener;
+import org.apache.activemq.util.ServiceSupport;
 import org.axiondb.engine.commands.ShutdownCommand;
 
 import edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue;

Copied: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java (from r359554, incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/XARecoveryBrokerTest.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java?p2=incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java&p1=incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/XARecoveryBrokerTest.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/activemq/broker/XARecoveryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,23 +14,23 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker;
+package org.apache.activemq.broker;
 
 import junit.framework.Test;
 
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.DataArrayResponse;
-import org.activemq.command.Message;
-import org.activemq.command.MessageAck;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.Response;
-import org.activemq.command.SessionInfo;
-import org.activemq.command.TransactionId;
-import org.activemq.command.TransactionInfo;
-import org.activemq.command.XATransactionId;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.DataArrayResponse;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.command.SessionInfo;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.command.TransactionInfo;
+import org.apache.activemq.command.XATransactionId;
 
 /**
  * Used to simulate the recovery that occurs when a broker shuts down.

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/advisory/AdvisoryBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -16,21 +16,21 @@
 * limitations under the License.
 *
 **/
-package org.activemq.broker.advisory;
+package org.apache.activemq.broker.advisory;
 
 import junit.framework.Test;
 
-import org.activemq.advisory.AdvisorySupport;
-import org.activemq.broker.BrokerTestSupport;
-import org.activemq.broker.StubConnection;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.RemoveInfo;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.advisory.AdvisorySupport;
+import org.apache.activemq.broker.BrokerTestSupport;
+import org.apache.activemq.broker.StubConnection;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+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.RemoveInfo;
+import org.apache.activemq.command.SessionInfo;
 
 public class AdvisoryBrokerTest extends BrokerTestSupport {
      

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreBrokerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreBrokerTest.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.broker.store;
+package org.apache.activemq.broker.store;
 
 import java.io.File;
 import java.io.IOException;
@@ -27,13 +27,13 @@
 
 import junit.framework.Test;
 
-import org.activemq.broker.BrokerFactory;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.BrokerTest;
-import org.activemq.store.DefaultPersistenceAdapterFactory;
-import org.activemq.store.PersistenceAdapter;
-import org.activemq.store.jdbc.JDBCPersistenceAdapter;
-import org.activemq.store.journal.JournalPersistenceAdapter;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.BrokerTest;
+import org.apache.activemq.store.DefaultPersistenceAdapterFactory;
+import org.apache.activemq.store.PersistenceAdapter;
+import org.apache.activemq.store.jdbc.JDBCPersistenceAdapter;
+import org.apache.activemq.store.journal.JournalPersistenceAdapter;
 
 /**
  * Once the wire format is completed we can test against real persistence storage.

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreRecoveryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreRecoveryBrokerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreRecoveryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreRecoveryBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.store;
+package org.apache.activemq.broker.store;
 
 import java.net.URI;
 
 import junit.framework.Test;
 
-import org.activemq.broker.BrokerFactory;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.RecoveryBrokerTest;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.RecoveryBrokerTest;
 
 /**
  * Used to verify that recovery works correctly against 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreXARecoveryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreXARecoveryBrokerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreXARecoveryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/DefaultStoreXARecoveryBrokerTest.java Wed Dec 28 09:24:02 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.broker.store;
+package org.apache.activemq.broker.store;
 
 import java.net.URI;
 
 import junit.framework.Test;
 
-import org.activemq.broker.BrokerFactory;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.XARecoveryBrokerTest;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.XARecoveryBrokerTest;
 
 /**
  * Used to verify that recovery works correctly against 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/LoadTester.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/LoadTester.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/LoadTester.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/LoadTester.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.broker.store;
+package org.apache.activemq.broker.store;
 
 import java.io.IOException;
 import java.net.URI;
@@ -29,14 +29,14 @@
 
 import junit.framework.Test;
 
-import org.activemq.ActiveMQConnectionFactory;
-import org.activemq.JmsTestSupport;
-import org.activemq.broker.BrokerFactory;
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.ProgressPrinter;
-import org.activemq.broker.TransportConnector;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQQueue;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.JmsTestSupport;
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.ProgressPrinter;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
 
 /**
  * 
@@ -45,7 +45,7 @@
 public class LoadTester extends JmsTestSupport {
 
     protected BrokerService createBroker() throws Exception {
-         return BrokerFactory.createBroker(new URI("xbean:org/activemq/broker/store/loadtester.xml"));
+         return BrokerFactory.createBroker(new URI("xbean:org/apache/activemq/broker/store/loadtester.xml"));
     }
     
     protected ConnectionFactory createConnectionFactory() throws URISyntaxException, IOException {

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalRecoveryBrokerTest.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.broker.store;
+package org.apache.activemq.broker.store;
 
 import junit.framework.Test;
 
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.RecoveryBrokerTest;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.RecoveryBrokerTest;
 
 /**
  * Used to verify that recovery works correctly against 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/store/QuickJournalXARecoveryBrokerTest.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.broker.store;
+package org.apache.activemq.broker.store;
 
 import junit.framework.Test;
 
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.XARecoveryBrokerTest;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.XARecoveryBrokerTest;
 
 /**
  * Used to verify that recovery works correctly against 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQBytesMessageTest.java Wed Dec 28 09:24:02 2005
@@ -14,12 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import javax.jms.JMSException;
 import javax.jms.MessageFormatException;
 import javax.jms.MessageNotReadableException;
 import javax.jms.MessageNotWriteableException;
+
+import org.apache.activemq.command.ActiveMQBytesMessage;
+import org.apache.activemq.command.CommandTypes;
 
 import junit.framework.TestCase;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQDestinationTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 import java.util.Map;
+
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTempQueue;
+import org.apache.activemq.command.ActiveMQTempTopic;
+import org.apache.activemq.command.ActiveMQTopic;
 
 import junit.framework.Test;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMapMessageTest.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.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -25,6 +25,8 @@
 import javax.jms.MessageFormatException;
 import javax.jms.MessageNotReadableException;
 import javax.jms.MessageNotWriteableException;
+
+import org.apache.activemq.command.ActiveMQMapMessage;
 
 import junit.framework.TestCase;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQMessageTest.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.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 import java.util.Enumeration;
@@ -29,8 +29,15 @@
 
 import org.activeio.ByteSequence;
 import org.activeio.command.WireFormat;
-import org.activemq.openwire.OpenWireFormat;
-import org.activemq.state.CommandVisitor;
+import org.apache.activemq.command.ActiveMQBytesMessage;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQTempTopic;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.command.CommandTypes;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.openwire.OpenWireFormat;
+import org.apache.activemq.state.CommandVisitor;
 
 /**
  * @version $Revision$
@@ -377,8 +384,8 @@
     }
 
     public void testConvertProperties() throws Exception {
-        org.activemq.command.Message msg = new org.activemq.command.Message() {
-            public org.activemq.command.Message copy() {
+        org.apache.activemq.command.Message msg = new org.apache.activemq.command.Message() {
+            public org.apache.activemq.command.Message copy() {
                 return null;
             }
             public void beforeMarshall(WireFormat wireFormat) throws IOException {
@@ -774,7 +781,7 @@
         String propertyName = "property";
         Object obj = new Object();
         try {
-            ((org.activemq.command.Message)msg).setProperty(propertyName, obj); //bypass object check
+            ((org.apache.activemq.command.Message)msg).setProperty(propertyName, obj); //bypass object check
         } catch (IOException e) {
         }
         try {

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQObjectMessageTest.java Wed Dec 28 09:24:02 2005
@@ -14,13 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import junit.framework.TestCase;
 
 import javax.jms.JMSException;
 import javax.jms.MessageNotReadableException;
 import javax.jms.MessageNotWriteableException;
+
+import org.apache.activemq.command.ActiveMQObjectMessage;
+
 import java.io.IOException;
 
 /**

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQStreamMessageTest.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.command;
+package org.apache.activemq.command;
 
 import java.io.Serializable;
 
@@ -22,6 +22,9 @@
 import javax.jms.MessageFormatException;
 import javax.jms.MessageNotReadableException;
 import javax.jms.MessageNotWriteableException;
+
+import org.apache.activemq.command.ActiveMQStreamMessage;
+import org.apache.activemq.command.CommandTypes;
 
 import junit.framework.TestCase;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/ActiveMQTextMessageTest.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.command;
+package org.apache.activemq.command;
 
 import java.io.IOException;
 
@@ -26,6 +26,9 @@
 import junit.textui.TestRunner;
 
 import org.activeio.ByteSequence;
+import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.activemq.command.CommandTypes;
+import org.apache.activemq.command.Message;
 
 /**
  * @version $Revision$

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/DataStructureTestSupport.java Wed Dec 28 09:24:02 2005
@@ -14,12 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import org.activeio.Packet;
 import org.activeio.command.WireFormat;
-import org.activemq.CombinationTestSupport;
-import org.activemq.openwire.OpenWireFormat;
+import org.apache.activemq.CombinationTestSupport;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.openwire.OpenWireFormat;
 
 import java.io.IOException;
 import java.lang.reflect.InvocationTargetException;

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageSendTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageSendTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageSendTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageSendTest.java Wed Dec 28 09:24:02 2005
@@ -14,9 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import org.activeio.ByteSequence;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ConnectionId;
+import org.apache.activemq.command.MessageId;
+import org.apache.activemq.command.ProducerId;
+import org.apache.activemq.command.SessionId;
 
 import java.io.IOException;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageTest.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageTest.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/command/MessageTest.java Wed Dec 28 09:24:02 2005
@@ -14,10 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.command;
+package org.apache.activemq.command;
 
 import org.activeio.command.WireFormat;
-import org.activemq.openwire.OpenWireFormat;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.MessageId;
+import org.apache.activemq.openwire.OpenWireFormat;
 
 import java.io.IOException;
 

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleConsumer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleConsumer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleConsumer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleConsumer.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.Connection;
 import javax.jms.ConnectionFactory;

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleProducer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleProducer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleProducer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/SimpleProducer.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
 



Mime
View raw message