activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r359567 [9/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/main/java/org/apache/activemq/transport/InactivityIOException.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/InactivityIOException.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityIOException.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityIOException.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/InactivityIOException.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/InactivityIOException.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityIOException.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/InactivityMonitor.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/InactivityMonitor.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/InactivityMonitor.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 
-import org.activemq.command.KeepAliveInfo;
-import org.activemq.management.CountStatisticImpl;
-import org.activemq.thread.Scheduler;
+import org.apache.activemq.command.KeepAliveInfo;
+import org.apache.activemq.management.CountStatisticImpl;
+import org.apache.activemq.thread.Scheduler;
 
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MarshallingTransportFilter.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/MarshallingTransportFilter.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MarshallingTransportFilter.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MarshallingTransportFilter.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/MarshallingTransportFilter.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/MarshallingTransportFilter.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/MarshallingTransportFilter.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 
 import org.activeio.command.WireFormat;
-import org.activemq.command.Command;
+import org.apache.activemq.command.Command;
 
 public class MarshallingTransportFilter extends TransportFilter {
 

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

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/ResponseCorrelator.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/ResponseCorrelator.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/ResponseCorrelator.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 
-import org.activemq.command.Command;
-import org.activemq.command.Response;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/Transport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/Transport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/Transport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java Wed Dec 28 09:24:02 2005
@@ -16,11 +16,11 @@
 * limitations under the License.
 *
 **/
-package org.activemq.transport;
+package org.apache.activemq.transport;
 
-import org.activemq.Service;
-import org.activemq.command.Command;
-import org.activemq.command.Response;
+import org.apache.activemq.Service;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
 
 import java.io.IOException;
 

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

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFactory.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportFactory.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFactory.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFactory.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportFactory.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFactory.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.transport;
+package org.apache.activemq.transport;
 
 import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
 import edu.emory.mathcs.backport.java.util.concurrent.Executor;
@@ -22,9 +22,9 @@
 import org.activeio.FactoryFinder;
 import org.activeio.command.WireFormat;
 import org.activeio.command.WireFormatFactory;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
 
 import java.io.IOException;
 import java.net.MalformedURLException;
@@ -46,8 +46,8 @@
         return doCompositeConnect(location);
     }
 
-    static final private FactoryFinder transportFactoryFinder = new FactoryFinder("META-INF/services/org/activemq/transport/");
-    static final private FactoryFinder wireFormatFactoryFinder = new FactoryFinder("META-INF/services/org/activemq/wireformat/");
+    static final private FactoryFinder transportFactoryFinder = new FactoryFinder("META-INF/services/org/apache/activemq/transport/");
+    static final private FactoryFinder wireFormatFactoryFinder = new FactoryFinder("META-INF/services/org/apache/activemq/wireformat/");
 
     static final private ConcurrentHashMap transportFactorys = new ConcurrentHashMap();
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportFilter.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportFilter.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportFilter.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 
-import org.activemq.command.Command;
-import org.activemq.command.Response;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
 
 
 /**
@@ -46,7 +46,7 @@
 
 
     /**
-     * @see org.activemq.Service#start()
+     * @see org.apache.activemq.Service#start()
      * @throws IOException if the next channel has not been set.
      */
     public void start() throws Exception {
@@ -58,7 +58,7 @@
     }
 
     /**
-     * @see org.activemq.Service#stop()
+     * @see org.apache.activemq.Service#stop()
      */
     public void stop() throws Exception {
         next.stop();

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportListener.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportListener.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportListener.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportListener.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportListener.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportListener.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportListener.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 
-import org.activemq.command.Command;
+import org.apache.activemq.command.Command;
 
 /**
  * An asynchronous listener of commands

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportLogger.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportLogger.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportLogger.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 
-import org.activemq.command.Command;
+import org.apache.activemq.command.Command;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

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

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerFilter.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportServerFilter.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerFilter.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerFilter.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportServerFilter.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportServerFilter.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerFilter.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.transport;
+package org.apache.activemq.transport;
 
 import java.net.URI;
 
-import org.activemq.command.BrokerInfo;
+import org.apache.activemq.command.BrokerInfo;
 
 public class TransportServerFilter implements TransportServer {
 

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

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerThreadSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportServerThreadSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerThreadSupport.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerThreadSupport.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportServerThreadSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportServerThreadSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportServerThreadSupport.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.transport;
+package org.apache.activemq.transport;
 
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
 
-import org.activemq.ThreadPriorities;
-import org.activemq.util.ServiceStopper;
+import org.apache.activemq.ThreadPriorities;
+import org.apache.activemq.util.ServiceStopper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.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.transport;
+package org.apache.activemq.transport;
 
-import org.activemq.command.Command;
-import org.activemq.command.Response;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportThreadSupport.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportThreadSupport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportThreadSupport.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportThreadSupport.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportThreadSupport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/TransportThreadSupport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportThreadSupport.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.transport;
+package org.apache.activemq.transport;
 
-import org.activemq.util.ServiceStopper;
+import org.apache.activemq.util.ServiceStopper;
 
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/WireFormatNegotiator.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/WireFormatNegotiator.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/WireFormatNegotiator.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.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.transport;
+package org.apache.activemq.transport;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
 
 import org.activeio.command.WireFormat;
-import org.activemq.command.Command;
-import org.activemq.command.WireFormatInfo;
-import org.activemq.openwire.OpenWireFormat;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.WireFormatInfo;
+import org.apache.activemq.openwire.OpenWireFormat;
 
 import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransport.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.transport.activeio;
+package org.apache.activemq.transport.activeio;
 
 import java.io.IOException;
 import java.net.SocketException;
 
 import org.activeio.command.AsyncCommandChannel;
 import org.activeio.net.SocketMetadata;
-import org.activemq.command.Command;
-import org.activemq.command.Response;
-import org.activemq.command.WireFormatInfo;
-import org.activemq.management.CountStatisticImpl;
-import org.activemq.transport.FutureResponse;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportListener;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.command.WireFormatInfo;
+import org.apache.activemq.management.CountStatisticImpl;
+import org.apache.activemq.transport.FutureResponse;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportListener;
 
 /**
  * An implementation of the {@link Transport} interface using ActiveIO

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportFactory.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.transport.activeio;
+package org.apache.activemq.transport.activeio;
 
 import java.io.IOException;
 import java.net.URI;
@@ -29,17 +29,17 @@
 import org.activeio.command.AsyncChannelToAsyncCommandChannel;
 import org.activeio.command.WireFormat;
 import org.activeio.net.SocketMetadata;
-import org.activemq.transport.InactivityMonitor;
-import org.activemq.transport.MutexTransport;
-import org.activemq.transport.ResponseCorrelator;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportLogger;
-import org.activemq.transport.TransportServer;
-import org.activemq.transport.WireFormatNegotiator;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
+import org.apache.activemq.transport.InactivityMonitor;
+import org.apache.activemq.transport.MutexTransport;
+import org.apache.activemq.transport.ResponseCorrelator;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportLogger;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.transport.WireFormatNegotiator;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
 
 import edu.emory.mathcs.backport.java.util.concurrent.Executor;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportServer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportServer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActiveIOTransportServer.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.transport.activeio;
+package org.apache.activemq.transport.activeio;
 
 import java.io.IOException;
 import java.net.URI;
@@ -26,11 +26,11 @@
 import org.activeio.ChannelFactory;
 import org.activeio.command.WireFormat;
 import org.activeio.command.WireFormatFactory;
-import org.activemq.ThreadPriorities;
-import org.activemq.command.BrokerInfo;
-import org.activemq.openwire.OpenWireFormatFactory;
-import org.activemq.transport.TransportAcceptListener;
-import org.activemq.transport.TransportServer;
+import org.apache.activemq.ThreadPriorities;
+import org.apache.activemq.command.BrokerInfo;
+import org.apache.activemq.openwire.OpenWireFormatFactory;
+import org.apache.activemq.transport.TransportAcceptListener;
+import org.apache.activemq.transport.TransportServer;
 
 import edu.emory.mathcs.backport.java.util.concurrent.Executor;
 import edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActivityMonitor.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActivityMonitor.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActivityMonitor.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/ActivityMonitor.java Wed Dec 28 09:24:02 2005
@@ -16,14 +16,14 @@
 * limitations under the License.
 *
 **/
-package org.activemq.transport.activeio;
+package org.apache.activemq.transport.activeio;
 
 import java.io.IOException;
 
 import org.activeio.AsyncChannel;
 import org.activeio.FilterAsyncChannel;
 import org.activeio.Packet;
-import org.activemq.management.CountStatisticImpl;
+import org.apache.activemq.management.CountStatisticImpl;
 
 /**
  * Used to make sure that commands are arriving periodically from the peer of the transport.  

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/PacketAggregatingAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/PacketAggregatingAsyncChannel.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/PacketAggregatingAsyncChannel.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/activeio/PacketAggregatingAsyncChannel.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.transport.activeio;
+package org.apache.activemq.transport.activeio;
 
 import java.io.IOException;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgent.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryAgent.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgent.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgent.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryAgent.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryAgent.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgent.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.transport.discovery;
+package org.apache.activemq.transport.discovery;
 
 import java.io.IOException;
 
 import javax.jms.JMSException;
 
-import org.activemq.Service;
-import org.activemq.command.DiscoveryEvent;
+import org.apache.activemq.Service;
+import org.apache.activemq.command.DiscoveryEvent;
 
 /**
  * An agent used to discover other instances of a service. 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgentFactory.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryAgentFactory.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgentFactory.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgentFactory.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryAgentFactory.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryAgentFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgentFactory.java Wed Dec 28 09:24:02 2005
@@ -14,19 +14,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.transport.discovery;
+package org.apache.activemq.transport.discovery;
 
 import java.io.IOException;
 import java.net.URI;
 
 import org.activeio.FactoryFinder;
-import org.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IOExceptionSupport;
 
 import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
 
 public abstract class DiscoveryAgentFactory {
 
-    static final private FactoryFinder discoveryAgentFinder = new FactoryFinder("META-INF/services/org/activemq/transport/discoveryagent/");    
+    static final private FactoryFinder discoveryAgentFinder = new FactoryFinder("META-INF/services/org/apache/activemq/transport/discoveryagent/");    
     static final private ConcurrentHashMap discoveryAgentFactorys = new ConcurrentHashMap();
 
     /**

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryListener.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryListener.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryListener.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryListener.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryListener.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryListener.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryListener.java Wed Dec 28 09:24:02 2005
@@ -16,9 +16,9 @@
 * limitations under the License.
 *
 **/
-package org.activemq.transport.discovery;
+package org.apache.activemq.transport.discovery;
 
-import org.activemq.command.DiscoveryEvent;
+import org.apache.activemq.command.DiscoveryEvent;
 
 /**
  * A listener of services being added or removed from a network

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransport.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryTransport.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransport.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransport.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryTransport.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransport.java Wed Dec 28 09:24:02 2005
@@ -16,15 +16,15 @@
  * limitations under the License.
  *
  **/
-package org.activemq.transport.discovery;
+package org.apache.activemq.transport.discovery;
 
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
 
-import org.activemq.command.DiscoveryEvent;
-import org.activemq.transport.CompositeTransport;
-import org.activemq.transport.TransportFilter;
+import org.apache.activemq.command.DiscoveryEvent;
+import org.apache.activemq.transport.CompositeTransport;
+import org.apache.activemq.transport.TransportFilter;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransportFactory.java (from r359554, incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryTransportFactory.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransportFactory.java?p2=incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransportFactory.java&p1=incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryTransportFactory.java&r1=359554&r2=359567&rev=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/discovery/DiscoveryTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryTransportFactory.java Wed Dec 28 09:24:02 2005
@@ -14,18 +14,18 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.transport.discovery;
+package org.apache.activemq.transport.discovery;
 
 import java.io.IOException;
 import java.net.URI;
 import java.util.HashMap;
 import java.util.Map;
 
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportServer;
-import org.activemq.transport.failover.FailoverTransportFactory;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport.CompositeData;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.transport.failover.FailoverTransportFactory;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport.CompositeData;
 
 /**
  * @version $Revision$

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.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.transport.discovery.multicast;
+package org.apache.activemq.transport.discovery.multicast;
 
 import java.io.IOException;
 import java.net.DatagramPacket;
@@ -26,9 +26,10 @@
 import java.net.URI;
 import java.util.Iterator;
 import java.util.Map;
-import org.activemq.command.DiscoveryEvent;
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryListener;
+
+import org.apache.activemq.command.DiscoveryEvent;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryListener;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgentFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgentFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgentFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgentFactory.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.transport.discovery.multicast;
+package org.apache.activemq.transport.discovery.multicast;
 
 import java.io.IOException;
 import java.net.URI;
 import java.util.Map;
 
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryAgentFactory;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryAgentFactory;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
 
 public class MulticastDiscoveryAgentFactory extends DiscoveryAgentFactory {
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/JmDNSFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/JmDNSFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/JmDNSFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/JmDNSFactory.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.transport.discovery.rendezvous;
+package org.apache.activemq.transport.discovery.rendezvous;
 
 import java.io.IOException;
 import java.net.InetAddress;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgent.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgent.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgent.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgent.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.transport.discovery.rendezvous;
+package org.apache.activemq.transport.discovery.rendezvous;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -28,11 +28,11 @@
 import javax.jmdns.ServiceInfo;
 import javax.jmdns.ServiceListener;
 
-import org.activemq.command.DiscoveryEvent;
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryListener;
-import org.activemq.util.JMSExceptionSupport;
-import org.activemq.util.MapHelper;
+import org.apache.activemq.command.DiscoveryEvent;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryListener;
+import org.apache.activemq.util.JMSExceptionSupport;
+import org.apache.activemq.util.MapHelper;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgentFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgentFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgentFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgentFactory.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.transport.discovery.rendezvous;
+package org.apache.activemq.transport.discovery.rendezvous;
 
 import java.io.IOException;
 import java.net.URI;
 import java.util.Map;
 
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryAgentFactory;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryAgentFactory;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
 
 public class RendezvousDiscoveryAgentFactory extends DiscoveryAgentFactory {
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.transport.discovery.simple;
+package org.apache.activemq.transport.discovery.simple;
 
 import java.io.IOException;
 import java.net.URI;
 
-import org.activemq.command.DiscoveryEvent;
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryListener;
+import org.apache.activemq.command.DiscoveryEvent;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryListener;
 
 /**
  * A simple DiscoveryAgent that allows static configuration of the discovered services.

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgentFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgentFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgentFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgentFactory.java Wed Dec 28 09:24:02 2005
@@ -16,18 +16,18 @@
  * limitations under the License.
  *
  **/
-package org.activemq.transport.discovery.simple;
+package org.apache.activemq.transport.discovery.simple;
 
 import java.io.IOException;
 import java.net.URI;
 import java.util.Map;
 
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryAgentFactory;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
-import org.activemq.util.URISupport.CompositeData;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryAgentFactory;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
+import org.apache.activemq.util.URISupport.CompositeData;
 
 public class SimpleDiscoveryAgentFactory extends DiscoveryAgentFactory {
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.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.transport.failover;
+package org.apache.activemq.transport.failover;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
@@ -23,19 +23,19 @@
 import java.util.Iterator;
 import java.util.Random;
 
-import org.activemq.command.Command;
-import org.activemq.command.Response;
-import org.activemq.state.ConnectionStateTracker;
-import org.activemq.thread.DefaultThreadPools;
-import org.activemq.thread.Task;
-import org.activemq.thread.TaskRunner;
-import org.activemq.transport.CompositeTransport;
-import org.activemq.transport.FutureResponse;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportListener;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.ServiceSupport;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.state.ConnectionStateTracker;
+import org.apache.activemq.thread.DefaultThreadPools;
+import org.apache.activemq.thread.Task;
+import org.apache.activemq.thread.TaskRunner;
+import org.apache.activemq.transport.CompositeTransport;
+import org.apache.activemq.transport.FutureResponse;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportListener;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.ServiceSupport;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransportFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransportFactory.java Wed Dec 28 09:24:02 2005
@@ -14,21 +14,21 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.transport.failover;
+package org.apache.activemq.transport.failover;
 
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.util.Map;
 
-import org.activemq.transport.MutexTransport;
-import org.activemq.transport.ResponseCorrelator;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportServer;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
-import org.activemq.util.URISupport.CompositeData;
+import org.apache.activemq.transport.MutexTransport;
+import org.apache.activemq.transport.ResponseCorrelator;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
+import org.apache.activemq.util.URISupport.CompositeData;
 
 public class FailoverTransportFactory extends TransportFactory {
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.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.transport.fanout;
+package org.apache.activemq.transport.fanout;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
@@ -22,21 +22,21 @@
 import java.util.ArrayList;
 import java.util.Iterator;
 
-import org.activemq.command.Command;
-import org.activemq.command.ConsumerInfo;
-import org.activemq.command.Message;
-import org.activemq.command.Response;
-import org.activemq.state.ConnectionStateTracker;
-import org.activemq.thread.DefaultThreadPools;
-import org.activemq.thread.Task;
-import org.activemq.thread.TaskRunner;
-import org.activemq.transport.CompositeTransport;
-import org.activemq.transport.FutureResponse;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportListener;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.ServiceSupport;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.ConsumerInfo;
+import org.apache.activemq.command.Message;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.state.ConnectionStateTracker;
+import org.apache.activemq.thread.DefaultThreadPools;
+import org.apache.activemq.thread.Task;
+import org.apache.activemq.thread.TaskRunner;
+import org.apache.activemq.transport.CompositeTransport;
+import org.apache.activemq.transport.FutureResponse;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportListener;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.ServiceSupport;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.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.transport.fanout;
+package org.apache.activemq.transport.fanout;
 
 import java.io.IOException;
 import java.net.URI;
@@ -22,17 +22,17 @@
 import java.util.HashMap;
 import java.util.Map;
 
-import org.activemq.transport.MutexTransport;
-import org.activemq.transport.ResponseCorrelator;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportServer;
-import org.activemq.transport.discovery.DiscoveryAgent;
-import org.activemq.transport.discovery.DiscoveryAgentFactory;
-import org.activemq.transport.discovery.DiscoveryTransport;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
-import org.activemq.util.URISupport.CompositeData;
+import org.apache.activemq.transport.MutexTransport;
+import org.apache.activemq.transport.ResponseCorrelator;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.transport.discovery.DiscoveryAgent;
+import org.apache.activemq.transport.discovery.DiscoveryAgentFactory;
+import org.apache.activemq.transport.discovery.DiscoveryTransport;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
+import org.apache.activemq.util.URISupport.CompositeData;
 
 public class FanoutTransportFactory extends TransportFactory {
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.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.transport.mock;
+package org.apache.activemq.transport.mock;
 
 import java.io.IOException;
 
-import org.activemq.command.Command;
-import org.activemq.command.Response;
-import org.activemq.transport.FutureResponse;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFilter;
-import org.activemq.transport.TransportListener;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.transport.FutureResponse;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFilter;
+import org.apache.activemq.transport.TransportListener;
 
 
 /**
@@ -50,7 +50,7 @@
 
 
     /**
-     * @see org.activemq.Service#start()
+     * @see org.apache.activemq.Service#start()
      * @throws IOException if the next channel has not been set.
      */
     public void start() throws Exception {
@@ -62,7 +62,7 @@
     }
 
     /**
-     * @see org.activemq.Service#stop()
+     * @see org.apache.activemq.Service#stop()
      */
     public void stop() throws Exception {
         next.stop();

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransportFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransportFactory.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.transport.mock;
+package org.apache.activemq.transport.mock;
 
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
 
-import org.activemq.transport.MutexTransport;
-import org.activemq.transport.ResponseCorrelator;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportServer;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
-import org.activemq.util.URISupport.CompositeData;
+import org.apache.activemq.transport.MutexTransport;
+import org.apache.activemq.transport.ResponseCorrelator;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
+import org.apache.activemq.util.URISupport.CompositeData;
 
 public class MockTransportFactory extends TransportFactory {
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/peer/PeerTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/peer/PeerTransportFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/peer/PeerTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/peer/PeerTransportFactory.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.transport.peer;
+package org.apache.activemq.transport.peer;
 
 import java.io.IOException;
 import java.net.URI;
@@ -22,17 +22,17 @@
 import java.util.HashMap;
 import java.util.Map;
 
-import org.activemq.broker.BrokerService;
-import org.activemq.broker.TransportConnector;
-import org.activemq.broker.BrokerFactory.BrokerFactoryHandler;
-import org.activemq.transport.Transport;
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportServer;
-import org.activemq.transport.vm.VMTransportFactory;
-import org.activemq.util.IOExceptionSupport;
-import org.activemq.util.IdGenerator;
-import org.activemq.util.IntrospectionSupport;
-import org.activemq.util.URISupport;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.broker.BrokerFactory.BrokerFactoryHandler;
+import org.apache.activemq.transport.Transport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.transport.vm.VMTransportFactory;
+import org.apache.activemq.util.IOExceptionSupport;
+import org.apache.activemq.util.IdGenerator;
+import org.apache.activemq.util.IntrospectionSupport;
+import org.apache.activemq.util.URISupport;
 
 import edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Abort.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Abort.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Abort.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Abort.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.TransactionId;
-import org.activemq.command.TransactionInfo;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.command.TransactionInfo;
 
 import java.io.DataInput;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Ack.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Ack.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Ack.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Ack.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import java.io.DataInput;
 import java.io.IOException;
 import java.net.ProtocolException;
 import java.util.Properties;
 
-import org.activemq.command.MessageAck;
-import org.activemq.command.TransactionId;
+import org.apache.activemq.command.MessageAck;
+import org.apache.activemq.command.TransactionId;
 
 class Ack implements StompCommand {
     private final StompWireFormat format;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/AsyncHelper.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/AsyncHelper.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/AsyncHelper.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/AsyncHelper.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 class AsyncHelper {
     public static Object tryUntilNotInterrupted(HelperWithReturn helper) {

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Begin.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Begin.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Begin.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Begin.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.TransactionId;
-import org.activemq.command.TransactionInfo;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.command.TransactionInfo;
 
 import java.io.DataInput;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Command.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Command.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Command.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Command.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import javax.jms.JMSException;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandEnvelope.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandEnvelope.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandEnvelope.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandEnvelope.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.Command;
+import org.apache.activemq.command.Command;
 
 import java.util.Properties;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandParser.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandParser.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandParser.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/CommandParser.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.Command;
-import org.activemq.command.Response;
+import org.apache.activemq.command.Command;
+import org.apache.activemq.command.Response;
 
 import javax.jms.JMSException;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Commit.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Commit.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Commit.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Commit.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.TransactionId;
-import org.activemq.command.TransactionInfo;
+import org.apache.activemq.command.TransactionId;
+import org.apache.activemq.command.TransactionInfo;
 
 import java.io.DataInput;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 import java.util.Properties;
 
-import org.activemq.command.ConnectionInfo;
-import org.activemq.command.ProducerInfo;
-import org.activemq.command.Response;
-import org.activemq.command.SessionInfo;
+import org.apache.activemq.command.ConnectionInfo;
+import org.apache.activemq.command.ProducerInfo;
+import org.apache.activemq.command.Response;
+import org.apache.activemq.command.SessionInfo;
 
 class Connect implements StompCommand {
     private HeaderParser headerParser = new HeaderParser();

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/DestinationNamer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/DestinationNamer.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/DestinationNamer.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/DestinationNamer.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQDestination;
 
 import javax.jms.Destination;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Disconnect.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Disconnect.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Disconnect.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Disconnect.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.ShutdownInfo;
+import org.apache.activemq.command.ShutdownInfo;
 
 import java.io.DataInput;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameBuilder.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQMessage;
 
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/HeaderParser.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/HeaderParser.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/HeaderParser.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/HeaderParser.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import java.io.BufferedReader;
 import java.io.DataInput;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ResponseListener.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ResponseListener.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ResponseListener.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ResponseListener.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
-import org.activemq.command.Response;
+import org.apache.activemq.command.Response;
 
 import java.io.DataOutput;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Send.java Wed Dec 28 09:24:02 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activemq.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import org.activeio.ByteSequence;
-import org.activemq.command.ActiveMQBytesMessage;
-import org.activemq.command.ActiveMQDestination;
-import org.activemq.command.ActiveMQMessage;
-import org.activemq.command.ActiveMQTextMessage;
-import org.activemq.command.TransactionId;
+import org.apache.activemq.command.ActiveMQBytesMessage;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQMessage;
+import org.apache.activemq.command.ActiveMQTextMessage;
+import org.apache.activemq.command.TransactionId;
 
 import javax.jms.JMSException;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 public interface Stomp {
     String NULL = "\u0000";

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompCommand.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompCommand.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompCommand.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import javax.jms.JMSException;
 

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompTransportFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompTransportFactory.java?rev=359567&r1=359554&r2=359567&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompTransportFactory.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompTransportFactory.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.transport.stomp;
+package org.apache.activemq.transport.stomp;
 
 import java.io.IOException;
 import java.net.URI;
 import java.net.URISyntaxException;
 
-import org.activemq.transport.TransportFactory;
-import org.activemq.transport.TransportServer;
-import org.activemq.util.IOExceptionSupport;
+import org.apache.activemq.transport.TransportFactory;
+import org.apache.activemq.transport.TransportServer;
+import org.apache.activemq.util.IOExceptionSupport;
 
 /**
  * A <a href="http://stomp.codehaus.org/">Stomp</a> transport factory



Mime
View raw message