activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r358596 [3/5] - in /incubator/activemq/trunk/activeio: ./ activeio-aio/src/main/java/org/activeio/packet/async/aio/ activeio-aio/src/main/java/org/apache/ activeio-aio/src/main/java/org/apache/activeio/ activeio-aio/src/main/java/org/apache...
Date Thu, 22 Dec 2005 17:53:13 GMT
Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/async/FilterAsyncChannelServer.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/async/FilterAsyncChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/async/FilterAsyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/FilterAsyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -14,18 +14,18 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.activeio.packet.async;
+package org.apache.activeio.packet.async;
 
 import java.io.IOException;
 import java.net.URI;
 
-import org.activeio.AcceptListener;
-import org.activeio.Channel;
+import org.apache.activeio.AcceptListener;
+import org.apache.activeio.Channel;
 
 
 /**
- * A AsyncChannelFilter can be used as a filter between a {@see org.activeio.AsyncChannel}
- * and it's {@see org.activeio.ChannelConsumer}.  Most {@see org.activeio.AsyncChannel}
+ * A AsyncChannelFilter can be used as a filter between a {@see org.apache.activeio.AsyncChannel}
+ * and it's {@see org.apache.activeio.ChannelConsumer}.  Most {@see org.apache.activeio.AsyncChannel}
  * that are not directly accessing the network will extends the AsyncChannelFilter since they act as a
  * filter between the client and the network.  O 
  * 
@@ -52,14 +52,14 @@
     }
     
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         next.dispose();
     }
 
     /**
-     * @see org.activeio.Service#start()
+     * @see org.apache.activeio.Service#start()
      * @throws IOException if the next channel has not been set.
      */
     public void start() throws IOException {
@@ -69,7 +69,7 @@
     }
 
     /**
-     * @see org.activeio.Service#stop()
+     * @see org.apache.activeio.Service#stop()
      */
     public void stop() throws IOException {
         next.stop();

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/AsyncWriteAsyncChannel.java Thu Dec 22 09:51:34 2005
@@ -1,4 +1,4 @@
-package org.activeio.packet.async.filter;
+package org.apache.activeio.packet.async.filter;
 
 import edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue;
 import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
@@ -8,10 +8,10 @@
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicInteger;
 
-import org.activeio.ChannelFactory;
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.FilterAsyncChannel;
+import org.apache.activeio.ChannelFactory;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.FilterAsyncChannel;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/CounterAsyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,21 +14,21 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.activeio.packet.async.filter;
+package org.apache.activeio.packet.async.filter;
 
 import java.io.IOException;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.FilterAsyncChannel;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.FilterAsyncChannel;
 
 
 /**
- * A CounterAsyncChannel is a simple {@see org.activeio.AsyncChannelFilter} 
+ * A CounterAsyncChannel is a simple {@see org.apache.activeio.AsyncChannelFilter} 
  * that counts the number bytes that been sent down and up through the channel.
  * 
- * The {@see org.activeio.counter.CounterAttribueEnum.COUNTER_INBOUND_COUNT}
- * and {@see org.activeio.counter.CounterAttribueEnum.COUNTER_OUTBOUND_COUNT}
+ * The {@see org.apache.activeio.counter.CounterAttribueEnum.COUNTER_INBOUND_COUNT}
+ * and {@see org.apache.activeio.counter.CounterAttribueEnum.COUNTER_OUTBOUND_COUNT}
  * attributes can be used to find query the channel to get the current inbound and outbound
  * byte counts.
  * 
@@ -48,7 +48,7 @@
     }
 
     /**
-     * @see org.activeio.packet.async.FilterAsyncChannel#onPacket(org.activeio.packet.Packet)
+     * @see org.apache.activeio.packet.async.FilterAsyncChannel#onPacket(org.apache.activeio.packet.Packet)
      */
     public void onPacket(Packet packet) {
         inBoundCounter += packet.remaining();
@@ -56,7 +56,7 @@
     }
 
     /**
-     * @see org.activeio.packet.async.FilterAsyncChannel#write(org.activeio.packet.Packet)
+     * @see org.apache.activeio.packet.async.FilterAsyncChannel#write(org.apache.activeio.packet.Packet)
      */
     public void write(Packet packet) throws IOException {
         outBoundCounter += packet.position();

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/PacketAggregatingAsyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,14 +14,14 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.activeio.packet.async.filter;
+package org.apache.activeio.packet.async.filter;
 
 import java.io.IOException;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.FilterAsyncChannel;
-import org.activeio.util.PacketAggregator;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.FilterAsyncChannel;
+import org.apache.activeio.util.PacketAggregator;
 
 /**
  * This PacketAggregatingAsyncChannel can be used when the client is sending a
@@ -32,7 +32,7 @@
  * Packet that is sent down will not be fragmented or combined with other Packet
  * objects.
  * 
- * This {@see org.activeio.AsyncChannel} adds a 4 byte header
+ * This {@see org.apache.activeio.AsyncChannel} adds a 4 byte header
  * to each packet that is sent down.
  * 
  * @version $Revision$

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/SynchornizedAsyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,14 +14,14 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.activeio.packet.async.filter;
+package org.apache.activeio.packet.async.filter;
 
 import edu.emory.mathcs.backport.java.util.concurrent.locks.Lock;
 import edu.emory.mathcs.backport.java.util.concurrent.locks.ReentrantLock;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.FilterAsyncChannel;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.FilterAsyncChannel;
 
 import java.io.IOException;
 

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/filter/WriteBufferedAsyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,14 +14,14 @@
  *  See the License for the specific language governing permissions and
  *  limitations under the License.
  */
-package org.activeio.packet.async.filter;
+package org.apache.activeio.packet.async.filter;
 
 import java.io.IOException;
 
-import org.activeio.packet.ByteArrayPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.FilterAsyncChannel;
+import org.apache.activeio.packet.ByteArrayPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.FilterAsyncChannel;
 
 /**
  */

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannel.java Thu Dec 22 09:51:34 2005
@@ -16,7 +16,7 @@
  * 
  **/
 
-package org.activeio.packet.async.nio;
+package org.apache.activeio.packet.async.nio;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
@@ -25,15 +25,15 @@
 import java.nio.channels.SelectionKey;
 import java.nio.channels.SocketChannel;
 
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.packet.ByteSequence;
-import org.activeio.packet.EOSPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.AsyncChannelListener;
-import org.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SelectorManagerListener;
-import org.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SocketChannelAsyncChannelSelection;
-import org.activeio.packet.sync.nio.NIOBaseChannel;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.packet.ByteSequence;
+import org.apache.activeio.packet.EOSPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.AsyncChannelListener;
+import org.apache.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SelectorManagerListener;
+import org.apache.activeio.packet.async.nio.NIOAsyncChannelSelectorManager.SocketChannelAsyncChannelSelection;
+import org.apache.activeio.packet.sync.nio.NIOBaseChannel;
 
 /**
  * @version $Revision$

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License. 
  * 
  **/
-package org.activeio.packet.async.nio;
+package org.apache.activeio.packet.async.nio;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -25,23 +25,23 @@
 import java.nio.channels.ServerSocketChannel;
 import java.nio.channels.SocketChannel;
 
-import org.activeio.adapter.SyncToAsyncChannelServer;
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.AsyncChannelFactory;
-import org.activeio.packet.async.AsyncChannelServer;
-import org.activeio.packet.async.filter.WriteBufferedAsyncChannel;
-import org.activeio.util.URISupport;
+import org.apache.activeio.adapter.SyncToAsyncChannelServer;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.AsyncChannelFactory;
+import org.apache.activeio.packet.async.AsyncChannelServer;
+import org.apache.activeio.packet.async.filter.WriteBufferedAsyncChannel;
+import org.apache.activeio.util.URISupport;
 
 /**
- * A TcpAsyncChannelFactory creates {@see org.activeio.net.TcpAsyncChannel}
- * and {@see org.activeio.net.TcpAsyncChannelServer} objects.
+ * A TcpAsyncChannelFactory creates {@see org.apache.activeio.net.TcpAsyncChannel}
+ * and {@see org.apache.activeio.net.TcpAsyncChannelServer} objects.
  * 
  * @version $Revision$
  */
 public class NIOAsyncChannelFactory implements AsyncChannelFactory {
     
-    protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.activeio.net.nio.BufferSize", ""+(64*1024)));
+    protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.apache.activeio.net.nio.BufferSize", ""+(64*1024)));
 
     protected static final int DEFAULT_BACKLOG = 500;
     boolean useDirectBuffers = true;
@@ -60,7 +60,7 @@
     /**
      * Uses the {@param location}'s host and port to create a tcp connection to a remote host.
      * 
-     * @see org.activeio.AsyncChannelFactory#openAsyncChannel(java.net.URI)
+     * @see org.apache.activeio.AsyncChannelFactory#openAsyncChannel(java.net.URI)
      */
     public AsyncChannel openAsyncChannel(URI location) throws IOException {
         SocketChannel channel = SocketChannel.open();
@@ -84,7 +84,7 @@
     /**
      * Binds a server socket a the {@param location}'s port. 
      * 
-     * @see org.activeio.AsyncChannelFactory#bindAsyncChannel(java.net.URI)
+     * @see org.apache.activeio.AsyncChannelFactory#bindAsyncChannel(java.net.URI)
      */
     public AsyncChannelServer bindAsyncChannel(URI bindURI) throws IOException {
         

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelSelectorManager.java Thu Dec 22 09:51:34 2005
@@ -15,12 +15,12 @@
  *  limitations under the License.
  */
 
-package org.activeio.packet.async.nio;
+package org.apache.activeio.packet.async.nio;
 
 import edu.emory.mathcs.backport.java.util.concurrent.Executor;
 import edu.emory.mathcs.backport.java.util.concurrent.ScheduledThreadPoolExecutor;
 
-import org.activeio.ChannelFactory;
+import org.apache.activeio.ChannelFactory;
 
 import java.io.IOException;
 import java.nio.channels.ClosedChannelException;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/nio/NIOAsyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -16,22 +16,22 @@
  * 
  **/
 
-package org.activeio.packet.async.nio;
+package org.apache.activeio.packet.async.nio;
 
 import java.io.IOException;
 import java.net.URI;
 import java.nio.channels.ServerSocketChannel;
 
-import org.activeio.Channel;
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.filter.WriteBufferedAsyncChannel;
-import org.activeio.packet.sync.socket.SocketSyncChannelServer;
-import org.activeio.stream.sync.socket.SocketStreamChannel;
+import org.apache.activeio.Channel;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.filter.WriteBufferedAsyncChannel;
+import org.apache.activeio.packet.sync.socket.SocketSyncChannelServer;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannel;
 
 /**
  * A SynchChannelServer that creates
- * {@see org.activeio.net.TcpSynchChannel}objects from accepted
+ * {@see org.apache.activeio.net.TcpSynchChannel}objects from accepted
  * tcp socket connections.
  * 
  * @version $Revision$

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License. 
  * 
  **/
-package org.activeio.packet.async.vmpipe;
+package org.apache.activeio.packet.async.vmpipe;
 
 import java.io.IOException;
 import java.lang.reflect.InvocationHandler;
@@ -27,11 +27,11 @@
 import java.util.HashMap;
 import java.util.Map;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.AsyncChannelFactory;
-import org.activeio.packet.async.AsyncChannelListener;
-import org.activeio.packet.async.AsyncChannelServer;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.AsyncChannelFactory;
+import org.apache.activeio.packet.async.AsyncChannelListener;
+import org.apache.activeio.packet.async.AsyncChannelServer;
 
 /**
  * 

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelPipe.java Thu Dec 22 09:51:34 2005
@@ -15,15 +15,15 @@
  * limitations under the License. 
  * 
  **/
-package org.activeio.packet.async.vmpipe;
+package org.apache.activeio.packet.async.vmpipe;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
 
-import org.activeio.packet.EOSPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.AsyncChannelListener;
+import org.apache.activeio.packet.EOSPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.AsyncChannelListener;
 
 import edu.emory.mathcs.backport.java.util.concurrent.Semaphore;
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/async/vmpipe/VMPipeAsyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -16,14 +16,14 @@
  * 
  **/
 
-package org.activeio.packet.async.vmpipe;
+package org.apache.activeio.packet.async.vmpipe;
 
 import java.io.IOException;
 import java.net.URI;
 
-import org.activeio.AcceptListener;
-import org.activeio.packet.async.AsyncChannel;
-import org.activeio.packet.async.AsyncChannelServer;
+import org.apache.activeio.AcceptListener;
+import org.apache.activeio.packet.async.AsyncChannel;
+import org.apache.activeio.packet.async.AsyncChannelServer;
 
 /**
  * @version $Revision$

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannel.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannel.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,16 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync;
+package org.apache.activeio.packet.sync;
 
 import java.io.IOException;
 
-import org.activeio.packet.Packet;
+import org.apache.activeio.packet.Packet;
 
 
 /**
- * A SynchChannelFilter can be used as a filter another {@see org.activeio.SynchChannel}
- * Most {@see org.activeio.SynchChannel} that are not directly accessing the network will 
+ * A SynchChannelFilter can be used as a filter another {@see org.apache.activeio.SynchChannel}
+ * Most {@see org.apache.activeio.SynchChannel} that are not directly accessing the network will 
  * extends the SynchChannelFilter since they act as a filter between the client and the network.
  *    
  * @version $Revision$
@@ -37,35 +37,35 @@
     }
 
     /**
-     * @see org.activeio.Channel#write(org.activeio.packet.Packet)
+     * @see org.apache.activeio.Channel#write(org.apache.activeio.packet.Packet)
      */
     public void write(Packet packet) throws IOException {
         next.write(packet);
     }
 
     /**
-     * @see org.activeio.Channel#flush()
+     * @see org.apache.activeio.Channel#flush()
      */
     public void flush() throws IOException {
         next.flush();
     }
 
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         next.dispose();
     }
 
     /**
-     * @see org.activeio.Service#start()
+     * @see org.apache.activeio.Service#start()
      */
     public void start() throws IOException {
         next.start();
     }
 
     /**
-     * @see org.activeio.Service#stop()
+     * @see org.apache.activeio.Service#stop()
      */
     public void stop() throws IOException {
         next.stop();
@@ -79,7 +79,7 @@
     }
 
     /**
-     * @see org.activeio.packet.sync.SyncChannel#read(long)
+     * @see org.apache.activeio.packet.sync.SyncChannel#read(long)
      */
     public Packet read(long timeout) throws IOException {
         return next.read(timeout);

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannelServer.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/FilterSyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/FilterSyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -14,17 +14,17 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync;
+package org.apache.activeio.packet.sync;
 
 import java.io.IOException;
 import java.net.URI;
 
-import org.activeio.Channel;
+import org.apache.activeio.Channel;
 
 
 /**
- * A SynchChannelFilter can be used as a filter another {@see org.activeio.SynchChannel}
- * Most {@see org.activeio.SynchChannel} that are not directly accessing the network will 
+ * A SynchChannelFilter can be used as a filter another {@see org.apache.activeio.SynchChannel}
+ * Most {@see org.apache.activeio.SynchChannel} that are not directly accessing the network will 
  * extends the SynchChannelFilter since they act as a filter between the client and the network.
  *    
  * @version $Revision$
@@ -38,21 +38,21 @@
     }
 
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         next.dispose();
     }
 
     /**
-     * @see org.activeio.Service#start()
+     * @see org.apache.activeio.Service#start()
      */
     public void start() throws IOException {
         next.start();
     }
 
     /**
-     * @see org.activeio.Service#stop()
+     * @see org.apache.activeio.Service#stop()
      */
     public void stop() throws IOException {
         next.stop();
@@ -66,21 +66,21 @@
     }
 
     /**
-     * @see org.activeio.packet.sync.SyncChannelServer#accept(long)
+     * @see org.apache.activeio.packet.sync.SyncChannelServer#accept(long)
      */
     public Channel accept(long timeout) throws IOException {
         return next.accept(timeout);
     }
 
     /**
-     * @see org.activeio.ChannelServer#getBindURI()
+     * @see org.apache.activeio.ChannelServer#getBindURI()
      */
     public URI getBindURI() {
         return next.getBindURI();
     }
 
     /**
-     * @see org.activeio.ChannelServer#getConnectURI()
+     * @see org.apache.activeio.ChannelServer#getConnectURI()
      */
     public URI getConnectURI() {
         return next.getConnectURI();

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannel.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannel.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannel.java Thu Dec 22 09:51:34 2005
@@ -15,17 +15,17 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync;
+package org.apache.activeio.packet.sync;
 
 import java.io.IOException;
 
-import org.activeio.Channel;
-import org.activeio.packet.Packet;
+import org.apache.activeio.Channel;
+import org.apache.activeio.packet.Packet;
 
 
 /**
  * SyncChannel objects allow threaded to synchronously block on the <code>receiveUpPacket</code>
- * method to get 'up' {@see org.activeio.Packet} objects when they arrive.
+ * method to get 'up' {@see org.apache.activeio.Packet} objects when they arrive.
  * 
  * @version $Revision$
  */

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelFactory.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelFactory.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync;
+package org.apache.activeio.packet.sync;
 
 import java.io.IOException;
 import java.net.URI;
 
 /**
- * SynchChannelFactory objects can create {@see org.activeio.SynchChannel}
- * and {@see org.activeio.SynchChannelServer} objects. 
+ * SynchChannelFactory objects can create {@see org.apache.activeio.SynchChannel}
+ * and {@see org.apache.activeio.SynchChannelServer} objects. 
  * 
  * @version $Revision$
  */

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelServer.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/packet/sync/SyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/SyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -14,18 +14,18 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync;
+package org.apache.activeio.packet.sync;
 
 import java.io.IOException;
 
-import org.activeio.Channel;
-import org.activeio.ChannelServer;
+import org.apache.activeio.Channel;
+import org.apache.activeio.ChannelServer;
 
 
 
 /**
  * A SynchChannelServer object provides an <code>accept</code> method to synchronously 
- * accept and create {@see org.activeio.Channel} objects.
+ * accept and create {@see org.apache.activeio.Channel} objects.
  * 
  * @version $Revision$
  */

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramContext.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.datagram;
+package org.apache.activeio.packet.sync.datagram;
 
 import java.net.DatagramPacket;
 import java.net.InetAddress;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync.datagram;
+package org.apache.activeio.packet.sync.datagram;
 
 import java.io.IOException;
 import java.net.DatagramPacket;
@@ -23,15 +23,15 @@
 import java.net.SocketException;
 import java.net.SocketTimeoutException;
 
-import org.activeio.packet.ByteArrayPacket;
-import org.activeio.packet.ByteSequence;
-import org.activeio.packet.FilterPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.packet.ByteArrayPacket;
+import org.apache.activeio.packet.ByteSequence;
+import org.apache.activeio.packet.FilterPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelServer;
 
 /**
- * A {@see org.activeio.SynchChannel}implementation that uses
+ * A {@see org.apache.activeio.SynchChannel}implementation that uses
  * TCP to talk to the network.
  * 
  * @version $Revision$
@@ -83,9 +83,9 @@
     }
 
     /**
-     * @see org.activeio.packet.sync.SyncChannel#read(long)
+     * @see org.apache.activeio.packet.sync.SyncChannel#read(long)
      */
-    public org.activeio.packet.Packet read(long timeout) throws IOException {
+    public org.apache.activeio.packet.Packet read(long timeout) throws IOException {
         try {
 
             if (timeout == SyncChannelServer.WAIT_FOREVER_TIMEOUT)
@@ -116,9 +116,9 @@
     }
 
     /**
-     * @see org.activeio.Channel#write(org.activeio.packet.Packet)
+     * @see org.apache.activeio.Channel#write(org.apache.activeio.packet.Packet)
      */
-    public void write(org.activeio.packet.Packet packet) throws IOException {
+    public void write(org.apache.activeio.packet.Packet packet) throws IOException {
         ByteSequence sequence = packet.asByteSequence();
 
         DatagramContext context = (DatagramContext) packet.getAdapter(DatagramContext.class);
@@ -130,13 +130,13 @@
     }
 
     /**
-     * @see org.activeio.Channel#flush()
+     * @see org.apache.activeio.Channel#flush()
      */
     public void flush() throws IOException {
     }
 
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         if (disposed)

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/datagram/DatagramSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,20 +14,20 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.datagram;
+package org.apache.activeio.packet.sync.datagram;
 
 import java.io.IOException;
 import java.net.DatagramSocket;
 import java.net.InetAddress;
 import java.net.URI;
 
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelFactory;
-import org.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelFactory;
+import org.apache.activeio.packet.sync.SyncChannelServer;
 
 /**
- * A TcpSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel}
- * and {@see org.activeio.net.TcpSynchChannelServer} objects.
+ * A TcpSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel}
+ * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects.
  * 
  * @version $Revision$
  */
@@ -36,7 +36,7 @@
     /**
      * Uses the {@param location}'s host and port to create a tcp connection to a remote host.
      * 
-     * @see org.activeio.SynchChannelFactory#openSyncChannel(java.net.URI)
+     * @see org.apache.activeio.SynchChannelFactory#openSyncChannel(java.net.URI)
      */
     public SyncChannel openSyncChannel(URI location) throws IOException {
         DatagramSocket socket=null;
@@ -75,7 +75,7 @@
 
     /**
      * @throws IOException allways thrown.
-     * @see org.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI)
+     * @see org.apache.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI)
      */
     public SyncChannelServer bindSyncChannel(URI location) throws IOException {
         throw new IOException("A SynchChannelServer is not available for this channel.");

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PacketAggregatingSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.filter;
+package org.apache.activeio.packet.sync.filter;
 
 import java.io.IOException;
 import java.util.LinkedList;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.FilterSyncChannel;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.util.PacketAggregator;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.FilterSyncChannel;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.util.PacketAggregator;
 
 /**
  * This PacketAggregatingSynchChannel can be used when the client is sending a
@@ -33,7 +33,7 @@
  * Packet that is sent down will not be fragmented or combined with other Packet
  * objects.
  * 
- * This {@see org.activeio.SynchChannel} adds a 4 byte header
+ * This {@see org.apache.activeio.SynchChannel} adds a 4 byte header
  * to each packet that is sent down.
  * 
  * @version $Revision$

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/PushbackSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.filter;
+package org.apache.activeio.packet.sync.filter;
 
 import java.io.IOException;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.FilterSyncChannel;
-import org.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.FilterSyncChannel;
+import org.apache.activeio.packet.sync.SyncChannel;
 
 /**
  *

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/SynchornizedSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.filter;
+package org.apache.activeio.packet.sync.filter;
 
 import java.io.IOException;
 import java.io.InterruptedIOException;
 
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.FilterSyncChannel;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.FilterSyncChannel;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelServer;
 
 import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
 import edu.emory.mathcs.backport.java.util.concurrent.locks.Lock;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/filter/WriteBufferedSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.filter;
+package org.apache.activeio.packet.sync.filter;
 
 import java.io.IOException;
 
-import org.activeio.packet.ByteArrayPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.FilterSyncChannel;
-import org.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.ByteArrayPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.FilterSyncChannel;
+import org.apache.activeio.packet.sync.SyncChannel;
 
 /**
  */

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/jxta/JxtaSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.jxta;
+package org.apache.activeio.packet.sync.jxta;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -25,13 +25,13 @@
 import javax.net.ServerSocketFactory;
 import javax.net.SocketFactory;
 
-import org.activeio.packet.sync.socket.SocketSyncChannelFactory;
+import org.apache.activeio.packet.sync.socket.SocketSyncChannelFactory;
 import org.p2psockets.P2PServerSocket;
 import org.p2psockets.P2PSocket;
 
 /**
- * A SslSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel}
- * and {@see org.activeio.net.TcpSynchChannelServer} objects that use SSL.
+ * A SslSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel}
+ * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects that use SSL.
  * 
  * @version $Revision$
  */

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -14,13 +14,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.multicast;
+package org.apache.activeio.packet.sync.multicast;
 
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.MulticastSocket;
 
-import org.activeio.packet.sync.datagram.DatagramSocketSyncChannel;
+import org.apache.activeio.packet.sync.datagram.DatagramSocketSyncChannel;
 
 
 /**

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/multicast/MulticastSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.multicast;
+package org.apache.activeio.packet.sync.multicast;
 
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.MulticastSocket;
 import java.net.URI;
 
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelServer;
 
 
 /**

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOBaseChannel.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync.nio;
+package org.apache.activeio.packet.sync.nio;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -25,8 +25,8 @@
 import java.nio.ByteBuffer;
 import java.nio.channels.SocketChannel;
 
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.stream.sync.socket.SocketMetadata;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.stream.sync.socket.SocketMetadata;
 
 /**
  * Base class for the Async and Sync implementations of NIO channels.
@@ -95,7 +95,7 @@
 	}
 
     /**
-     * @see org.activeio.Channel#flush()
+     * @see org.apache.activeio.Channel#flush()
      */
     public void flush() throws IOException {
     }

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -15,23 +15,23 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync.nio;
+package org.apache.activeio.packet.sync.nio;
 
 import java.io.IOException;
 import java.net.SocketTimeoutException;
 import java.nio.ByteBuffer;
 import java.nio.channels.SocketChannel;
 
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.packet.ByteSequence;
-import org.activeio.packet.EOSPacket;
-import org.activeio.packet.EmptyPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.packet.ByteSequence;
+import org.apache.activeio.packet.EOSPacket;
+import org.apache.activeio.packet.EmptyPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelServer;
 
 /**
- * A {@see org.activeio.SynchChannel} implementation that uses a {@see java.nio.channels.SocketChannel}
+ * A {@see org.apache.activeio.SynchChannel} implementation that uses a {@see java.nio.channels.SocketChannel}
  * to talk to the network.
  * 
  * Using a SocketChannelSynchChannel should be more efficient than using a SocketSynchChannel since

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.nio;
+package org.apache.activeio.packet.sync.nio;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -24,22 +24,22 @@
 import java.nio.channels.ServerSocketChannel;
 import java.nio.channels.SocketChannel;
 
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelFactory;
-import org.activeio.packet.sync.SyncChannelServer;
-import org.activeio.packet.sync.filter.WriteBufferedSyncChannel;
-import org.activeio.util.URISupport;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelFactory;
+import org.apache.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.packet.sync.filter.WriteBufferedSyncChannel;
+import org.apache.activeio.util.URISupport;
 
 /**
- * A TcpSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel}
- * and {@see org.activeio.net.TcpSynchChannelServer} objects.
+ * A TcpSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel}
+ * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects.
  * 
  * @version $Revision$
  */
 public class NIOSyncChannelFactory implements SyncChannelFactory {
 
-    protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.activeio.net.nio.BufferSize", ""+(64*1024)));
+    protected static final int DEFAULT_BUFFER_SIZE = Integer.parseInt(System.getProperty("org.apache.activeio.net.nio.BufferSize", ""+(64*1024)));
 
     protected static final int DEFAULT_BACKLOG = 500;
     boolean useDirectBuffers = true;
@@ -58,7 +58,7 @@
     /**
      * Uses the {@param location}'s host and port to create a tcp connection to a remote host.
      * 
-     * @see org.activeio.SynchChannelFactory#openSyncChannel(java.net.URI)
+     * @see org.apache.activeio.SynchChannelFactory#openSyncChannel(java.net.URI)
      */
     public SyncChannel openSyncChannel(URI location) throws IOException {
         SocketChannel channel = SocketChannel.open();
@@ -82,7 +82,7 @@
     /**
      * Binds a server socket a the {@param location}'s port. 
      * 
-     * @see org.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI)
+     * @see org.apache.activeio.SynchChannelFactory#bindSynchChannel(java.net.URI)
      */
     public SyncChannelServer bindSyncChannel(URI bindURI) throws IOException {
         

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/nio/NIOSyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -15,22 +15,22 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync.nio;
+package org.apache.activeio.packet.sync.nio;
 
 import java.io.IOException;
 import java.net.URI;
 import java.nio.channels.ServerSocketChannel;
 
-import org.activeio.Channel;
-import org.activeio.packet.ByteBufferPacket;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.filter.WriteBufferedSyncChannel;
-import org.activeio.packet.sync.socket.SocketSyncChannelServer;
-import org.activeio.stream.sync.socket.SocketStreamChannel;
+import org.apache.activeio.Channel;
+import org.apache.activeio.packet.ByteBufferPacket;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.filter.WriteBufferedSyncChannel;
+import org.apache.activeio.packet.sync.socket.SocketSyncChannelServer;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannel;
 
 /**
  * A SynchChannelServer that creates
- * {@see org.activeio.net.TcpSynchChannel}objects from accepted
+ * {@see org.apache.activeio.net.TcpSynchChannel}objects from accepted
  * tcp socket connections.
  * 
  * @version $Revision$

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannel.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync.socket;
+package org.apache.activeio.packet.sync.socket;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -23,17 +23,17 @@
 import java.net.Socket;
 import java.net.SocketTimeoutException;
 
-import org.activeio.packet.ByteArrayPacket;
-import org.activeio.packet.ByteSequence;
-import org.activeio.packet.EOSPacket;
-import org.activeio.packet.EmptyPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelServer;
-import org.activeio.stream.sync.socket.SocketStreamChannel;
+import org.apache.activeio.packet.ByteArrayPacket;
+import org.apache.activeio.packet.ByteSequence;
+import org.apache.activeio.packet.EOSPacket;
+import org.apache.activeio.packet.EmptyPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannel;
 
 /**
- * A {@see org.activeio.SynchChannel} implementation that uses a {@see java.net.Socket}
+ * A {@see org.apache.activeio.SynchChannel} implementation that uses a {@see java.net.Socket}
  *  to talk to the network.
  * 
  * @version $Revision$
@@ -59,9 +59,9 @@
     }
 
     /**
-     * @see org.activeio.SynchChannel#read(long)
+     * @see org.apache.activeio.SynchChannel#read(long)
      */
-    synchronized public org.activeio.packet.Packet read(long timeout) throws IOException {
+    synchronized public org.apache.activeio.packet.Packet read(long timeout) throws IOException {
         try {
             
             if( timeout==SyncChannelServer.WAIT_FOREVER_TIMEOUT )
@@ -104,21 +104,21 @@
 
     
     /**
-     * @see org.activeio.Channel#write(org.activeio.packet.Packet)
+     * @see org.apache.activeio.Channel#write(org.apache.activeio.packet.Packet)
      */
     public void write(Packet packet) throws IOException {
         packet.writeTo(os);
     }
 
     /**
-     * @see org.activeio.Channel#flush()
+     * @see org.apache.activeio.Channel#flush()
      */
     public void flush() throws IOException {
         os.flush();
     }
 
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         channel.dispose();

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.socket;
+package org.apache.activeio.packet.sync.socket;
 
 import java.io.IOException;
 import java.net.URI;
@@ -22,17 +22,17 @@
 import javax.net.ServerSocketFactory;
 import javax.net.SocketFactory;
 
-import org.activeio.packet.sync.SyncChannel;
-import org.activeio.packet.sync.SyncChannelFactory;
-import org.activeio.packet.sync.SyncChannelServer;
-import org.activeio.stream.sync.StreamChannelServer;
-import org.activeio.stream.sync.socket.SocketStreamChannel;
-import org.activeio.stream.sync.socket.SocketStreamChannelFactory;
-import org.activeio.stream.sync.socket.SocketStreamChannelServer;
+import org.apache.activeio.packet.sync.SyncChannel;
+import org.apache.activeio.packet.sync.SyncChannelFactory;
+import org.apache.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.stream.sync.StreamChannelServer;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannel;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannelFactory;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannelServer;
 
 /**
- * A TcpSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel}
- * and {@see org.activeio.net.TcpSynchChannelServer} objects.
+ * A TcpSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel}
+ * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects.
  * 
  * @version $Revision$
  */
@@ -51,7 +51,7 @@
     /**
      * Uses the {@param location}'s host and port to create a tcp connection to a remote host.
      * 
-     * @see org.activeio.SyncChannelFactory#openSyncChannel(java.net.URI)
+     * @see org.apache.activeio.SyncChannelFactory#openSyncChannel(java.net.URI)
      */
     public SyncChannel openSyncChannel(URI location) throws IOException {
         SocketStreamChannel channel = (SocketStreamChannel) factory.openStreamChannel(location);
@@ -70,7 +70,7 @@
     /**
      * Binds a server socket a the {@param bindURI}'s port.
      * 
-     * @see org.activeio.SyncChannelFactory#bindSyncChannel(java.net.URI)
+     * @see org.apache.activeio.SyncChannelFactory#bindSyncChannel(java.net.URI)
      */
     public SyncChannelServer bindSyncChannel(URI bindURI) throws IOException {
         StreamChannelServer server = factory.bindStreamChannel(bindURI);

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/socket/SocketSyncChannelServer.java Thu Dec 22 09:51:34 2005
@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package org.activeio.packet.sync.socket;
+package org.apache.activeio.packet.sync.socket;
 
 import java.io.IOException;
 import java.net.ServerSocket;
 import java.net.URI;
 
-import org.activeio.Channel;
-import org.activeio.packet.sync.SyncChannelServer;
-import org.activeio.stream.sync.socket.SocketStreamChannel;
-import org.activeio.stream.sync.socket.SocketStreamChannelServer;
+import org.apache.activeio.Channel;
+import org.apache.activeio.packet.sync.SyncChannelServer;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannel;
+import org.apache.activeio.stream.sync.socket.SocketStreamChannelServer;
 
 /**
  * A SynchChannelServer that creates
- * {@see org.activeio.net.TcpSynchChannel}objects from accepted
+ * {@see org.apache.activeio.net.TcpSynchChannel}objects from accepted
  * TCP socket connections.
  * 
  * @version $Revision$
@@ -58,7 +58,7 @@
     }
 
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         server.dispose();

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/packet/sync/ssl/SslSocketSyncChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,16 +14,16 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.packet.sync.ssl;
+package org.apache.activeio.packet.sync.ssl;
 
 import javax.net.ssl.SSLServerSocketFactory;
 import javax.net.ssl.SSLSocketFactory;
 
-import org.activeio.packet.sync.socket.SocketSyncChannelFactory;
+import org.apache.activeio.packet.sync.socket.SocketSyncChannelFactory;
 
 /**
- * A SslSynchChannelFactory creates {@see org.activeio.net.TcpSynchChannel}
- * and {@see org.activeio.net.TcpSynchChannelServer} objects that use SSL.
+ * A SslSynchChannelFactory creates {@see org.apache.activeio.net.TcpSynchChannel}
+ * and {@see org.apache.activeio.net.TcpSynchChannelServer} objects that use SSL.
  * 
  * @version $Revision$
  */

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannel.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannel.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannel.java Thu Dec 22 09:51:34 2005
@@ -15,13 +15,13 @@
  * limitations under the License.
  */
 
-package org.activeio.stream.sync;
+package org.apache.activeio.stream.sync;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 
-import org.activeio.Channel;
+import org.apache.activeio.Channel;
 
 
 /**

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelFactory.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelFactory.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,14 +14,14 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.stream.sync;
+package org.apache.activeio.stream.sync;
 
 import java.io.IOException;
 import java.net.URI;
 
 /**
- * StreamChannelFactory objects can create {@see org.activeio.StreamChannel}
- * and {@see org.activeio.StreamChannelServer} objects. 
+ * StreamChannelFactory objects can create {@see org.apache.activeio.StreamChannel}
+ * and {@see org.apache.activeio.StreamChannelServer} objects. 
  * 
  * @version $Revision$
  */

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelServer.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelServer.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/stream/sync/StreamChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/StreamChannelServer.java Thu Dec 22 09:51:34 2005
@@ -14,18 +14,18 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.stream.sync;
+package org.apache.activeio.stream.sync;
 
 import java.io.IOException;
 
-import org.activeio.Channel;
-import org.activeio.ChannelServer;
+import org.apache.activeio.Channel;
+import org.apache.activeio.ChannelServer;
 
 
 
 /**
  * A StreamChannelServer object provides an <code>accept</code> method to synchronously 
- * accept and create {@see org.activeio.channel.Channel} objects.
+ * accept and create {@see org.apache.activeio.channel.Channel} objects.
  * 
  * @version $Revision$
  */

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketMetadata.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License. 
  * 
  **/
-package org.activeio.stream.sync.socket;
+package org.apache.activeio.stream.sync.socket;
 
 import java.net.InetAddress;
 import java.net.SocketAddress;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannel.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activeio.stream.sync.socket;
+package org.apache.activeio.stream.sync.socket;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -25,10 +25,10 @@
 import java.net.SocketAddress;
 import java.net.SocketException;
 
-import org.activeio.stream.sync.StreamChannel;
+import org.apache.activeio.stream.sync.StreamChannel;
 
 /**
- * A {@see org.activeio.StreamChannel} implementation that uses a {@see java.net.Socket}
+ * A {@see org.apache.activeio.StreamChannel} implementation that uses a {@see java.net.Socket}
  *  to talk to the network.
  * 
  * @version $Revision$
@@ -55,7 +55,7 @@
     }
     
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         if (disposed)

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelFactory.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.stream.sync.socket;
+package org.apache.activeio.stream.sync.socket;
 
 import java.io.IOException;
 import java.net.InetAddress;
@@ -26,14 +26,14 @@
 import javax.net.ServerSocketFactory;
 import javax.net.SocketFactory;
 
-import org.activeio.stream.sync.StreamChannel;
-import org.activeio.stream.sync.StreamChannelFactory;
-import org.activeio.stream.sync.StreamChannelServer;
-import org.activeio.util.URISupport;
+import org.apache.activeio.stream.sync.StreamChannel;
+import org.apache.activeio.stream.sync.StreamChannelFactory;
+import org.apache.activeio.stream.sync.StreamChannelServer;
+import org.apache.activeio.util.URISupport;
 
 /**
- * A TcpStreamChannelFactory creates {@see org.activeio.net.TcpStreamChannel}
- * and {@see org.activeio.net.TcpStreamChannelServer} objects.
+ * A TcpStreamChannelFactory creates {@see org.apache.activeio.net.TcpStreamChannel}
+ * and {@see org.apache.activeio.net.TcpStreamChannelServer} objects.
  * 
  * @version $Revision$
  */
@@ -57,7 +57,7 @@
     /**
      * Uses the {@param location}'s host and port to create a tcp connection to a remote host.
      * 
-     * @see org.activeio.StreamChannelFactory#openStreamChannel(java.net.URI)
+     * @see org.apache.activeio.StreamChannelFactory#openStreamChannel(java.net.URI)
      */
     public StreamChannel openStreamChannel(URI location) throws IOException {
         Socket socket=null;
@@ -77,7 +77,7 @@
     /**
      * Binds a server socket a the {@param bindURI}'s port.
      * 
-     * @see org.activeio.StreamChannelFactory#bindStreamChannel(java.net.URI)
+     * @see org.apache.activeio.StreamChannelFactory#bindStreamChannel(java.net.URI)
      */
     public StreamChannelServer bindStreamChannel(URI bindURI) throws IOException {
         

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/stream/sync/socket/SocketStreamChannelServer.java Thu Dec 22 09:51:34 2005
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.activeio.stream.sync.socket;
+package org.apache.activeio.stream.sync.socket;
 
 import java.io.IOException;
 import java.net.ServerSocket;
@@ -24,12 +24,12 @@
 import java.net.SocketTimeoutException;
 import java.net.URI;
 
-import org.activeio.Channel;
-import org.activeio.stream.sync.StreamChannelServer;
+import org.apache.activeio.Channel;
+import org.apache.activeio.stream.sync.StreamChannelServer;
 
 /**
  * A StreamChannelServer that creates
- * {@see org.activeio.net.TcpStreamChannel}objects from accepted
+ * {@see org.apache.activeio.net.TcpStreamChannel}objects from accepted
  * tcp socket connections.
  * 
  * @version $Revision$
@@ -82,7 +82,7 @@
     }
 
     /**
-     * @see org.activeio.Disposable#dispose()
+     * @see org.apache.activeio.Disposable#dispose()
      */
     public void dispose() {
         if (serverSocket == null)

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayInputStream.java Thu Dec 22 09:51:34 2005
@@ -14,12 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.util;
+package org.apache.activeio.util;
 
 import java.io.IOException;
 import java.io.InputStream;
 
-import org.activeio.packet.ByteSequence;
+import org.apache.activeio.packet.ByteSequence;
 
 /**
  * Very similar to the java.io.ByteArrayInputStream but this version 

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/ByteArrayOutputStream.java Thu Dec 22 09:51:34 2005
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.util;
+package org.apache.activeio.util;
 
 import java.io.OutputStream;
 
-import org.activeio.packet.ByteSequence;
+import org.apache.activeio.packet.ByteSequence;
 
 /**
  * Very similar to the java.io.ByteArrayOutputStream but this version 

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/FactoryFinder.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.util;
+package org.apache.activeio.util;
 
 import java.io.BufferedInputStream;
 import java.io.IOException;

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/PacketAggregator.java Thu Dec 22 09:51:34 2005
@@ -14,15 +14,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.util;
+package org.apache.activeio.util;
 
 import java.io.IOException;
 
-import org.activeio.packet.AppendedPacket;
-import org.activeio.packet.ByteArrayPacket;
-import org.activeio.packet.EOSPacket;
-import org.activeio.packet.Packet;
-import org.activeio.packet.PacketData;
+import org.apache.activeio.packet.AppendedPacket;
+import org.apache.activeio.packet.ByteArrayPacket;
+import org.apache.activeio.packet.EOSPacket;
+import org.apache.activeio.packet.Packet;
+import org.apache.activeio.packet.PacketData;
 
 /**
  * @version $Revision$

Modified: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java?rev=358596&r1=358590&r2=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/util/URISupport.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.util;
+package org.apache.activeio.util;
 
 import java.net.URI;
 import java.net.URISyntaxException;

Copied: incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java (from r358590, incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/xnet/ServerService.java)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java?p2=incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java&p1=incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/xnet/ServerService.java&r1=358590&r2=358596&rev=358596&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/java/org/activeio/xnet/ServerService.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/java/org/apache/activeio/xnet/ServerService.java Thu Dec 22 09:51:34 2005
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.activeio.xnet;
+package org.apache.activeio.xnet;
 
 import java.util.Properties;
 



Mime
View raw message