activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r379619 [16/30] - in /incubator/activemq/trunk: ./ activecluster/ activecluster/src/java/org/apache/activecluster/ activecluster/src/java/org/apache/activecluster/election/ activecluster/src/java/org/apache/activecluster/election/impl/ acti...
Date Tue, 21 Feb 2006 23:14:17 GMT
Modified: incubator/activemq/trunk/activeio/activeio-oneport-jetty/src/test/java/org/apache/activeio/oneport/jetty/TestServlet.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-jetty/src/test/java/org/apache/activeio/oneport/jetty/TestServlet.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-jetty/src/test/java/org/apache/activeio/oneport/jetty/TestServlet.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-jetty/src/test/java/org/apache/activeio/oneport/jetty/TestServlet.java Tue Feb 21 15:12:56 2006
@@ -1,42 +1,42 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.jetty;
-
-import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
-
-import java.io.IOException;
-
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-
-
-public class TestServlet extends HttpServlet {
-    
-    private static final long serialVersionUID = 3257286933137733686L;
-
-    protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
-        try {
-            JettyOnePortSocketListenerTest.staticResultSlot.offer("HTTP", 1, TimeUnit.MILLISECONDS);
-            resp.getOutputStream().print("Hello World!");
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }            
-    }
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.jetty;
+
+import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
+
+import java.io.IOException;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+
+
+public class TestServlet extends HttpServlet {
+    
+    private static final long serialVersionUID = 3257286933137733686L;
+
+    protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+        try {
+            JettyOnePortSocketListenerTest.staticResultSlot.offer("HTTP", 1, TimeUnit.MILLISECONDS);
+            resp.getOutputStream().print("Hello World!");
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }            
+    }
 }

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-jetty/src/test/java/org/apache/activeio/oneport/jetty/TestServlet.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/pom.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java Tue Feb 21 15:12:56 2006
@@ -1,40 +1,40 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-import org.omg.PortableInterceptor.ORBInitInfo;
-import org.openorb.orb.pi.FeatureInitInfo;
-import org.openorb.orb.pi.FeatureInitializer;
-
-/**
- * Used to hook in the OpenORBOpenPortSocketFactory into the ORB.
- */
-public class OpenORBOpenPortFeatureInitializer implements FeatureInitializer {
-    
-    static final private ThreadLocal socketFatory = new ThreadLocal();
-    
-    static public void setContextSocketFactory( OpenORBOpenPortSocketFactory sf ) {
-        socketFatory.set(sf);
-    }
-    
-    public void init(ORBInitInfo orbinfo, FeatureInitInfo featureinfo) {
-        OpenORBOpenPortSocketFactory sf = (OpenORBOpenPortSocketFactory) socketFatory.get();
-        if( sf!=null ) {
-            featureinfo.setFeature("IIOP.SocketFactory", sf);                    
-        }
-    }
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+import org.omg.PortableInterceptor.ORBInitInfo;
+import org.openorb.orb.pi.FeatureInitInfo;
+import org.openorb.orb.pi.FeatureInitializer;
+
+/**
+ * Used to hook in the OpenORBOpenPortSocketFactory into the ORB.
+ */
+public class OpenORBOpenPortFeatureInitializer implements FeatureInitializer {
+    
+    static final private ThreadLocal socketFatory = new ThreadLocal();
+    
+    static public void setContextSocketFactory( OpenORBOpenPortSocketFactory sf ) {
+        socketFatory.set(sf);
+    }
+    
+    public void init(ORBInitInfo orbinfo, FeatureInitInfo featureinfo) {
+        OpenORBOpenPortSocketFactory sf = (OpenORBOpenPortSocketFactory) socketFatory.get();
+        if( sf!=null ) {
+            featureinfo.setFeature("IIOP.SocketFactory", sf);                    
+        }
+    }
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java Tue Feb 21 15:12:56 2006
@@ -1,58 +1,58 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.ServerSocket;
-import java.net.Socket;
-
-import org.apache.activeio.adapter.AsyncToSyncChannelServer;
-import org.apache.activeio.adapter.SyncChannelServerToServerSocket;
-import org.apache.activeio.oneport.IIOPRecognizer;
-import org.apache.activeio.oneport.OnePortAsyncChannelServer;
-import org.apache.activeio.packet.sync.SyncChannelServer;
-import org.openorb.orb.net.SocketFactory;
-
-/**
- * 
- */
-public class OpenORBOpenPortSocketFactory implements SocketFactory {
-
-    private final OnePortAsyncChannelServer channelServer;
-
-    public OpenORBOpenPortSocketFactory(OnePortAsyncChannelServer channelServer) {
-        this.channelServer = channelServer;
-    }
-    
-    /**
-     * Outbound sockets are normal.
-     */
-    public Socket createSocket(InetAddress address, int port) throws IOException {
-        return new Socket(address, port);
-    }
-
-    /**
-     * Server sockets bind against the OnePortAsyncChannelServer.
-     */
-    public ServerSocket createServerSocket(InetAddress address, int port) throws IOException {
-        SyncChannelServer sychServer = AsyncToSyncChannelServer.adapt(channelServer.bindAsyncChannel(IIOPRecognizer.IIOP_RECOGNIZER));
-		sychServer.start();
-		return new SyncChannelServerToServerSocket(sychServer);
-    }
-    
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+import org.apache.activeio.adapter.AsyncToSyncChannelServer;
+import org.apache.activeio.adapter.SyncChannelServerToServerSocket;
+import org.apache.activeio.oneport.IIOPRecognizer;
+import org.apache.activeio.oneport.OnePortAsyncChannelServer;
+import org.apache.activeio.packet.sync.SyncChannelServer;
+import org.openorb.orb.net.SocketFactory;
+
+/**
+ * 
+ */
+public class OpenORBOpenPortSocketFactory implements SocketFactory {
+
+    private final OnePortAsyncChannelServer channelServer;
+
+    public OpenORBOpenPortSocketFactory(OnePortAsyncChannelServer channelServer) {
+        this.channelServer = channelServer;
+    }
+    
+    /**
+     * Outbound sockets are normal.
+     */
+    public Socket createSocket(InetAddress address, int port) throws IOException {
+        return new Socket(address, port);
+    }
+
+    /**
+     * Server sockets bind against the OnePortAsyncChannelServer.
+     */
+    public ServerSocket createServerSocket(InetAddress address, int port) throws IOException {
+        SyncChannelServer sychServer = AsyncToSyncChannelServer.adapt(channelServer.bindAsyncChannel(IIOPRecognizer.IIOP_RECOGNIZER));
+		sychServer.start();
+		return new SyncChannelServerToServerSocket(sychServer);
+    }
+    
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java Tue Feb 21 15:12:56 2006
@@ -1,90 +1,90 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-import java.rmi.RemoteException;
-import java.util.Properties;
-
-import javax.naming.NamingException;
-
-import org.apache.activeio.oneport.OnePortAsyncChannelServerTest;
-import org.omg.CORBA.ORB;
-import org.omg.CORBA.Object;
-import org.omg.PortableServer.POA;
-import org.omg.PortableServer.POAHelper;
-
-import edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue;
-
-/**
- * 
- */
-public class OpenORBOnePortSocketFactoryTest extends OnePortAsyncChannelServerTest {
-
-    static public BlockingQueue staticResultSlot;
-    private ORB orb;
-    private String serverRef;
-    private TestIIOPServerImpl testIIOPServer;
-    private POA rootPOA;
-
-    protected void startIIOPServer() throws Exception {
-        staticResultSlot = resultSlot;
-        
-        Properties props = new Properties();        
-        props.setProperty("org.omg.PortableInterceptor.ORBInitializerClass."+OpenORBOpenPortFeatureInitializer.class.getName(), "");
-        props.setProperty("org.omg.CORBA.ORBClass", "org.openorb.orb.core.ORB");
-        props.setProperty("org.omg.CORBA.ORBSingletonClass", "org.openorb.orb.core.ORBSingleton"); 
-
-        OpenORBOpenPortFeatureInitializer.setContextSocketFactory(new OpenORBOpenPortSocketFactory(server));	        
-        orb = ORB.init( new String[]{}, props );
-        OpenORBOpenPortFeatureInitializer.setContextSocketFactory(null);
-        
-        rootPOA = POAHelper.narrow( orb.resolve_initial_references( "RootPOA" ) );
-
-        TestIIOPServerImpl srv = new TestIIOPServerImpl();
-        serverRef = orb.object_to_string( srv._this( orb ) );
-        rootPOA.the_POAManager().activate();
-        new Thread(){
-            public void run() {
-	            orb.run();
-            }
-        }.start();
-    }
-    
-    protected void stopIIOPServer() throws Exception {
-        orb.shutdown(true);
-    }
-    
-    protected void hitIIOPServer( ) throws NamingException, RemoteException
-    {
-        // Create a client side orb.
-        Properties props = new Properties();        
-        props.setProperty("org.omg.CORBA.ORBClass", "org.openorb.orb.core.ORB");
-        props.setProperty("org.omg.CORBA.ORBSingletonClass", "org.openorb.orb.core.ORBSingleton"); 
-        ORB orb = ORB.init( new String[]{}, props );
-        
-        Object obj = orb.string_to_object( serverRef );
-        TestIIOPServer srv = TestIIOPServerHelper.narrow( obj );
-        try {
-            srv.test();
-        } catch (Throwable e) {
-            e.printStackTrace();
-        } finally {
-            orb.shutdown(true);
-        }
-    }
-                    
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+import java.rmi.RemoteException;
+import java.util.Properties;
+
+import javax.naming.NamingException;
+
+import org.apache.activeio.oneport.OnePortAsyncChannelServerTest;
+import org.omg.CORBA.ORB;
+import org.omg.CORBA.Object;
+import org.omg.PortableServer.POA;
+import org.omg.PortableServer.POAHelper;
+
+import edu.emory.mathcs.backport.java.util.concurrent.BlockingQueue;
+
+/**
+ * 
+ */
+public class OpenORBOnePortSocketFactoryTest extends OnePortAsyncChannelServerTest {
+
+    static public BlockingQueue staticResultSlot;
+    private ORB orb;
+    private String serverRef;
+    private TestIIOPServerImpl testIIOPServer;
+    private POA rootPOA;
+
+    protected void startIIOPServer() throws Exception {
+        staticResultSlot = resultSlot;
+        
+        Properties props = new Properties();        
+        props.setProperty("org.omg.PortableInterceptor.ORBInitializerClass."+OpenORBOpenPortFeatureInitializer.class.getName(), "");
+        props.setProperty("org.omg.CORBA.ORBClass", "org.openorb.orb.core.ORB");
+        props.setProperty("org.omg.CORBA.ORBSingletonClass", "org.openorb.orb.core.ORBSingleton"); 
+
+        OpenORBOpenPortFeatureInitializer.setContextSocketFactory(new OpenORBOpenPortSocketFactory(server));	        
+        orb = ORB.init( new String[]{}, props );
+        OpenORBOpenPortFeatureInitializer.setContextSocketFactory(null);
+        
+        rootPOA = POAHelper.narrow( orb.resolve_initial_references( "RootPOA" ) );
+
+        TestIIOPServerImpl srv = new TestIIOPServerImpl();
+        serverRef = orb.object_to_string( srv._this( orb ) );
+        rootPOA.the_POAManager().activate();
+        new Thread(){
+            public void run() {
+	            orb.run();
+            }
+        }.start();
+    }
+    
+    protected void stopIIOPServer() throws Exception {
+        orb.shutdown(true);
+    }
+    
+    protected void hitIIOPServer( ) throws NamingException, RemoteException
+    {
+        // Create a client side orb.
+        Properties props = new Properties();        
+        props.setProperty("org.omg.CORBA.ORBClass", "org.openorb.orb.core.ORB");
+        props.setProperty("org.omg.CORBA.ORBSingletonClass", "org.openorb.orb.core.ORBSingleton"); 
+        ORB orb = ORB.init( new String[]{}, props );
+        
+        Object obj = orb.string_to_object( serverRef );
+        TestIIOPServer srv = TestIIOPServerHelper.narrow( obj );
+        try {
+            srv.test();
+        } catch (Throwable e) {
+            e.printStackTrace();
+        } finally {
+            orb.shutdown(true);
+        }
+    }
+                    
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java Tue Feb 21 15:12:56 2006
@@ -1,26 +1,26 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-/**
- * Interface definition: TestIIOPServer.
- * 
- * @author OpenORB Compiler
- */
-public interface TestIIOPServer extends TestIIOPServerOperations, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity
-{
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+/**
+ * Interface definition: TestIIOPServer.
+ * 
+ * @author OpenORB Compiler
+ */
+public interface TestIIOPServer extends TestIIOPServerOperations, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity
+{
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java Tue Feb 21 15:12:56 2006
@@ -1,148 +1,148 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-
-/** 
- * Helper class for : TestIIOPServer
- *  
- * @author OpenORB Compiler
- */ 
-public class TestIIOPServerHelper
-{
-    /**
-     * Insert TestIIOPServer into an any
-     * @param a an any
-     * @param t TestIIOPServer value
-     */
-    public static void insert(org.omg.CORBA.Any a, org.apache.activeio.oneport.openorb.TestIIOPServer t)
-    {
-        a.insert_Object(t , type());
-    }
-
-    /**
-     * Extract TestIIOPServer from an any
-     *
-     * @param a an any
-     * @return the extracted TestIIOPServer value
-     */
-    public static org.apache.activeio.oneport.openorb.TestIIOPServer extract( org.omg.CORBA.Any a )
-    {
-        if ( !a.type().equivalent( type() ) )
-        {
-            throw new org.omg.CORBA.MARSHAL();
-        }
-        try
-        {
-            return org.apache.activeio.oneport.openorb.TestIIOPServerHelper.narrow( a.extract_Object() );
-        }
-        catch ( final org.omg.CORBA.BAD_PARAM e )
-        {
-            throw new org.omg.CORBA.MARSHAL(e.getMessage());
-        }
-    }
-
-    //
-    // Internal TypeCode value
-    //
-    private static org.omg.CORBA.TypeCode _tc = null;
-
-    /**
-     * Return the TestIIOPServer TypeCode
-     * @return a TypeCode
-     */
-    public static org.omg.CORBA.TypeCode type()
-    {
-        if (_tc == null) {
-            org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init();
-            _tc = orb.create_interface_tc( id(), "TestIIOPServer" );
-        }
-        return _tc;
-    }
-
-    /**
-     * Return the TestIIOPServer IDL ID
-     * @return an ID
-     */
-    public static String id()
-    {
-        return _id;
-    }
-
-    private final static String _id = "IDL:org/activeio/oneport/TestIIOPServer:1.0";
-
-    /**
-     * Read TestIIOPServer from a marshalled stream
-     * @param istream the input stream
-     * @return the readed TestIIOPServer value
-     */
-    public static org.apache.activeio.oneport.openorb.TestIIOPServer read(org.omg.CORBA.portable.InputStream istream)
-    {
-        return(org.apache.activeio.oneport.openorb.TestIIOPServer)istream.read_Object(org.apache.activeio.oneport.openorb._TestIIOPServerStub.class);
-    }
-
-    /**
-     * Write TestIIOPServer into a marshalled stream
-     * @param ostream the output stream
-     * @param value TestIIOPServer value
-     */
-    public static void write(org.omg.CORBA.portable.OutputStream ostream, org.apache.activeio.oneport.openorb.TestIIOPServer value)
-    {
-        ostream.write_Object((org.omg.CORBA.portable.ObjectImpl)value);
-    }
-
-    /**
-     * Narrow CORBA::Object to TestIIOPServer
-     * @param obj the CORBA Object
-     * @return TestIIOPServer Object
-     */
-    public static TestIIOPServer narrow(org.omg.CORBA.Object obj)
-    {
-        if (obj == null)
-            return null;
-        if (obj instanceof TestIIOPServer)
-            return (TestIIOPServer)obj;
-
-        if (obj._is_a(id()))
-        {
-            _TestIIOPServerStub stub = new _TestIIOPServerStub();
-            stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
-            return stub;
-        }
-
-        throw new org.omg.CORBA.BAD_PARAM();
-    }
-
-    /**
-     * Unchecked Narrow CORBA::Object to TestIIOPServer
-     * @param obj the CORBA Object
-     * @return TestIIOPServer Object
-     */
-    public static TestIIOPServer unchecked_narrow(org.omg.CORBA.Object obj)
-    {
-        if (obj == null)
-            return null;
-        if (obj instanceof TestIIOPServer)
-            return (TestIIOPServer)obj;
-
-        _TestIIOPServerStub stub = new _TestIIOPServerStub();
-        stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
-        return stub;
-
-    }
-
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+
+/** 
+ * Helper class for : TestIIOPServer
+ *  
+ * @author OpenORB Compiler
+ */ 
+public class TestIIOPServerHelper
+{
+    /**
+     * Insert TestIIOPServer into an any
+     * @param a an any
+     * @param t TestIIOPServer value
+     */
+    public static void insert(org.omg.CORBA.Any a, org.apache.activeio.oneport.openorb.TestIIOPServer t)
+    {
+        a.insert_Object(t , type());
+    }
+
+    /**
+     * Extract TestIIOPServer from an any
+     *
+     * @param a an any
+     * @return the extracted TestIIOPServer value
+     */
+    public static org.apache.activeio.oneport.openorb.TestIIOPServer extract( org.omg.CORBA.Any a )
+    {
+        if ( !a.type().equivalent( type() ) )
+        {
+            throw new org.omg.CORBA.MARSHAL();
+        }
+        try
+        {
+            return org.apache.activeio.oneport.openorb.TestIIOPServerHelper.narrow( a.extract_Object() );
+        }
+        catch ( final org.omg.CORBA.BAD_PARAM e )
+        {
+            throw new org.omg.CORBA.MARSHAL(e.getMessage());
+        }
+    }
+
+    //
+    // Internal TypeCode value
+    //
+    private static org.omg.CORBA.TypeCode _tc = null;
+
+    /**
+     * Return the TestIIOPServer TypeCode
+     * @return a TypeCode
+     */
+    public static org.omg.CORBA.TypeCode type()
+    {
+        if (_tc == null) {
+            org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init();
+            _tc = orb.create_interface_tc( id(), "TestIIOPServer" );
+        }
+        return _tc;
+    }
+
+    /**
+     * Return the TestIIOPServer IDL ID
+     * @return an ID
+     */
+    public static String id()
+    {
+        return _id;
+    }
+
+    private final static String _id = "IDL:org/activeio/oneport/TestIIOPServer:1.0";
+
+    /**
+     * Read TestIIOPServer from a marshalled stream
+     * @param istream the input stream
+     * @return the readed TestIIOPServer value
+     */
+    public static org.apache.activeio.oneport.openorb.TestIIOPServer read(org.omg.CORBA.portable.InputStream istream)
+    {
+        return(org.apache.activeio.oneport.openorb.TestIIOPServer)istream.read_Object(org.apache.activeio.oneport.openorb._TestIIOPServerStub.class);
+    }
+
+    /**
+     * Write TestIIOPServer into a marshalled stream
+     * @param ostream the output stream
+     * @param value TestIIOPServer value
+     */
+    public static void write(org.omg.CORBA.portable.OutputStream ostream, org.apache.activeio.oneport.openorb.TestIIOPServer value)
+    {
+        ostream.write_Object((org.omg.CORBA.portable.ObjectImpl)value);
+    }
+
+    /**
+     * Narrow CORBA::Object to TestIIOPServer
+     * @param obj the CORBA Object
+     * @return TestIIOPServer Object
+     */
+    public static TestIIOPServer narrow(org.omg.CORBA.Object obj)
+    {
+        if (obj == null)
+            return null;
+        if (obj instanceof TestIIOPServer)
+            return (TestIIOPServer)obj;
+
+        if (obj._is_a(id()))
+        {
+            _TestIIOPServerStub stub = new _TestIIOPServerStub();
+            stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
+            return stub;
+        }
+
+        throw new org.omg.CORBA.BAD_PARAM();
+    }
+
+    /**
+     * Unchecked Narrow CORBA::Object to TestIIOPServer
+     * @param obj the CORBA Object
+     * @return TestIIOPServer Object
+     */
+    public static TestIIOPServer unchecked_narrow(org.omg.CORBA.Object obj)
+    {
+        if (obj == null)
+            return null;
+        if (obj instanceof TestIIOPServer)
+            return (TestIIOPServer)obj;
+
+        _TestIIOPServerStub stub = new _TestIIOPServerStub();
+        stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
+        return stub;
+
+    }
+
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java Tue Feb 21 15:12:56 2006
@@ -1,74 +1,74 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-/**
- * Holder class for : TestIIOPServer
- * 
- * @author OpenORB Compiler
- */
-final public class TestIIOPServerHolder
-        implements org.omg.CORBA.portable.Streamable
-{
-    /**
-     * Internal TestIIOPServer value
-     */
-    public org.apache.activeio.oneport.openorb.TestIIOPServer value;
-
-    /**
-     * Default constructor
-     */
-    public TestIIOPServerHolder()
-    { }
-
-    /**
-     * Constructor with value initialisation
-     * @param initial the initial value
-     */
-    public TestIIOPServerHolder(org.apache.activeio.oneport.openorb.TestIIOPServer initial)
-    {
-        value = initial;
-    }
-
-    /**
-     * Read TestIIOPServer from a marshalled stream
-     * @param istream the input stream
-     */
-    public void _read(org.omg.CORBA.portable.InputStream istream)
-    {
-        value = TestIIOPServerHelper.read(istream);
-    }
-
-    /**
-     * Write TestIIOPServer into a marshalled stream
-     * @param ostream the output stream
-     */
-    public void _write(org.omg.CORBA.portable.OutputStream ostream)
-    {
-        TestIIOPServerHelper.write(ostream,value);
-    }
-
-    /**
-     * Return the TestIIOPServer TypeCode
-     * @return a TypeCode
-     */
-    public org.omg.CORBA.TypeCode _type()
-    {
-        return TestIIOPServerHelper.type();
-    }
-
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+/**
+ * Holder class for : TestIIOPServer
+ * 
+ * @author OpenORB Compiler
+ */
+final public class TestIIOPServerHolder
+        implements org.omg.CORBA.portable.Streamable
+{
+    /**
+     * Internal TestIIOPServer value
+     */
+    public org.apache.activeio.oneport.openorb.TestIIOPServer value;
+
+    /**
+     * Default constructor
+     */
+    public TestIIOPServerHolder()
+    { }
+
+    /**
+     * Constructor with value initialisation
+     * @param initial the initial value
+     */
+    public TestIIOPServerHolder(org.apache.activeio.oneport.openorb.TestIIOPServer initial)
+    {
+        value = initial;
+    }
+
+    /**
+     * Read TestIIOPServer from a marshalled stream
+     * @param istream the input stream
+     */
+    public void _read(org.omg.CORBA.portable.InputStream istream)
+    {
+        value = TestIIOPServerHelper.read(istream);
+    }
+
+    /**
+     * Write TestIIOPServer into a marshalled stream
+     * @param ostream the output stream
+     */
+    public void _write(org.omg.CORBA.portable.OutputStream ostream)
+    {
+        TestIIOPServerHelper.write(ostream,value);
+    }
+
+    /**
+     * Return the TestIIOPServer TypeCode
+     * @return a TypeCode
+     */
+    public org.omg.CORBA.TypeCode _type()
+    {
+        return TestIIOPServerHelper.type();
+    }
+
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java Tue Feb 21 15:12:56 2006
@@ -1,32 +1,32 @@
-
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
-
-/**
- * 
- */
-public class TestIIOPServerImpl extends TestIIOPServerPOA {
-    public void test() {
-        try {
-            OpenORBOnePortSocketFactoryTest.staticResultSlot.offer("IIOP", 1, TimeUnit.MILLISECONDS);
-        } catch (InterruptedException e) {
-        }
-    }
-}
+
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
+
+/**
+ * 
+ */
+public class TestIIOPServerImpl extends TestIIOPServerPOA {
+    public void test() {
+        try {
+            OpenORBOnePortSocketFactoryTest.staticResultSlot.offer("IIOP", 1, TimeUnit.MILLISECONDS);
+        } catch (InterruptedException e) {
+        }
+    }
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java Tue Feb 21 15:12:56 2006
@@ -1,31 +1,31 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-/**
- * Interface definition: TestIIOPServer.
- * 
- * @author OpenORB Compiler
- */
-public interface TestIIOPServerOperations
-{
-    /**
-     * Operation test
-     */
-    public void test();
-
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+/**
+ * Interface definition: TestIIOPServer.
+ * 
+ * @author OpenORB Compiler
+ */
+public interface TestIIOPServerOperations
+{
+    /**
+     * Operation test
+     */
+    public void test();
+
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java Tue Feb 21 15:12:56 2006
@@ -1,72 +1,72 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-/**
- * Interface definition: TestIIOPServer.
- * 
- * @author OpenORB Compiler
- */
-public abstract class TestIIOPServerPOA extends org.omg.PortableServer.Servant
-        implements TestIIOPServerOperations, org.omg.CORBA.portable.InvokeHandler
-{
-    public TestIIOPServer _this()
-    {
-        return TestIIOPServerHelper.narrow(_this_object());
-    }
-
-    public TestIIOPServer _this(org.omg.CORBA.ORB orb)
-    {
-        return TestIIOPServerHelper.narrow(_this_object(orb));
-    }
-
-    private static String [] _ids_list =
-    {
-        "IDL:org/activeio/oneport/TestIIOPServer:1.0"
-    };
-
-    public String[] _all_interfaces(org.omg.PortableServer.POA poa, byte [] objectId)
-    {
-        return _ids_list;
-    }
-
-    public final org.omg.CORBA.portable.OutputStream _invoke(final String opName,
-            final org.omg.CORBA.portable.InputStream _is,
-            final org.omg.CORBA.portable.ResponseHandler handler)
-    {
-
-        if (opName.equals("test")) {
-                return _invoke_test(_is, handler);
-        } else {
-            throw new org.omg.CORBA.BAD_OPERATION(opName);
-        }
-    }
-
-    // helper methods
-    private org.omg.CORBA.portable.OutputStream _invoke_test(
-            final org.omg.CORBA.portable.InputStream _is,
-            final org.omg.CORBA.portable.ResponseHandler handler) {
-        org.omg.CORBA.portable.OutputStream _output;
-
-        test();
-
-        _output = handler.createReply();
-
-        return _output;
-    }
-
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+/**
+ * Interface definition: TestIIOPServer.
+ * 
+ * @author OpenORB Compiler
+ */
+public abstract class TestIIOPServerPOA extends org.omg.PortableServer.Servant
+        implements TestIIOPServerOperations, org.omg.CORBA.portable.InvokeHandler
+{
+    public TestIIOPServer _this()
+    {
+        return TestIIOPServerHelper.narrow(_this_object());
+    }
+
+    public TestIIOPServer _this(org.omg.CORBA.ORB orb)
+    {
+        return TestIIOPServerHelper.narrow(_this_object(orb));
+    }
+
+    private static String [] _ids_list =
+    {
+        "IDL:org/activeio/oneport/TestIIOPServer:1.0"
+    };
+
+    public String[] _all_interfaces(org.omg.PortableServer.POA poa, byte [] objectId)
+    {
+        return _ids_list;
+    }
+
+    public final org.omg.CORBA.portable.OutputStream _invoke(final String opName,
+            final org.omg.CORBA.portable.InputStream _is,
+            final org.omg.CORBA.portable.ResponseHandler handler)
+    {
+
+        if (opName.equals("test")) {
+                return _invoke_test(_is, handler);
+        } else {
+            throw new org.omg.CORBA.BAD_OPERATION(opName);
+        }
+    }
+
+    // helper methods
+    private org.omg.CORBA.portable.OutputStream _invoke_test(
+            final org.omg.CORBA.portable.InputStream _is,
+            final org.omg.CORBA.portable.ResponseHandler handler) {
+        org.omg.CORBA.portable.OutputStream _output;
+
+        test();
+
+        _output = handler.createReply();
+
+        return _output;
+    }
+
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java Tue Feb 21 15:12:56 2006
@@ -1,89 +1,89 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-/**
- * Interface definition: TestIIOPServer.
- * 
- * @author OpenORB Compiler
- */
-public class TestIIOPServerPOATie extends TestIIOPServerPOA
-{
-
-    //
-    // Private reference to implementation object
-    //
-    private TestIIOPServerOperations _tie;
-
-    //
-    // Private reference to POA
-    //
-    private org.omg.PortableServer.POA _poa;
-
-    /**
-     * Constructor
-     */
-    public TestIIOPServerPOATie(TestIIOPServerOperations tieObject)
-    {
-        _tie = tieObject;
-    }
-
-    /**
-     * Constructor
-     */
-    public TestIIOPServerPOATie(TestIIOPServerOperations tieObject, org.omg.PortableServer.POA poa)
-    {
-        _tie = tieObject;
-        _poa = poa;
-    }
-
-    /**
-     * Get the delegate
-     */
-    public TestIIOPServerOperations _delegate()
-    {
-        return _tie;
-    }
-
-    /**
-     * Set the delegate
-     */
-    public void _delegate(TestIIOPServerOperations delegate_)
-    {
-        _tie = delegate_;
-    }
-
-    /**
-     * _default_POA method
-     */
-    public org.omg.PortableServer.POA _default_POA()
-    {
-        if (_poa != null)
-            return _poa;
-        else
-            return super._default_POA();
-    }
-
-    /**
-     * Operation test
-     */
-    public void test()
-    {
-        _tie.test();
-    }
-
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+/**
+ * Interface definition: TestIIOPServer.
+ * 
+ * @author OpenORB Compiler
+ */
+public class TestIIOPServerPOATie extends TestIIOPServerPOA
+{
+
+    //
+    // Private reference to implementation object
+    //
+    private TestIIOPServerOperations _tie;
+
+    //
+    // Private reference to POA
+    //
+    private org.omg.PortableServer.POA _poa;
+
+    /**
+     * Constructor
+     */
+    public TestIIOPServerPOATie(TestIIOPServerOperations tieObject)
+    {
+        _tie = tieObject;
+    }
+
+    /**
+     * Constructor
+     */
+    public TestIIOPServerPOATie(TestIIOPServerOperations tieObject, org.omg.PortableServer.POA poa)
+    {
+        _tie = tieObject;
+        _poa = poa;
+    }
+
+    /**
+     * Get the delegate
+     */
+    public TestIIOPServerOperations _delegate()
+    {
+        return _tie;
+    }
+
+    /**
+     * Set the delegate
+     */
+    public void _delegate(TestIIOPServerOperations delegate_)
+    {
+        _tie = delegate_;
+    }
+
+    /**
+     * _default_POA method
+     */
+    public org.omg.PortableServer.POA _default_POA()
+    {
+        if (_poa != null)
+            return _poa;
+        else
+            return super._default_POA();
+    }
+
+    /**
+     * Operation test
+     */
+    public void test()
+    {
+        _tie.test();
+    }
+
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java (original)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java Tue Feb 21 15:12:56 2006
@@ -1,89 +1,89 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activeio.oneport.openorb;
-
-
-/**
- * Interface definition: TestIIOPServer.
- * 
- * @author OpenORB Compiler
- */
-public class _TestIIOPServerStub extends org.omg.CORBA.portable.ObjectImpl
-        implements TestIIOPServer
-{
-    static final String[] _ids_list =
-    {
-        "IDL:org/activeio/oneport/TestIIOPServer:1.0"
-    };
-
-    public String[] _ids()
-    {
-     return _ids_list;
-    }
-
-    private final static Class _opsClass = org.apache.activeio.oneport.openorb.TestIIOPServerOperations.class;
-
-    /**
-     * Operation test
-     */
-    public void test()
-    {
-        while(true)
-        {
-            if (!this._is_local())
-            {
-                org.omg.CORBA.portable.InputStream _input = null;
-                try
-                {
-                    org.omg.CORBA.portable.OutputStream _output = this._request("test",true);
-                    _input = this._invoke(_output);
-                    return;
-                }
-                catch(org.omg.CORBA.portable.RemarshalException _exception)
-                {
-                    continue;
-                }
-                catch(org.omg.CORBA.portable.ApplicationException _exception)
-                {
-                    String _exception_id = _exception.getId();
-                    throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
-                }
-                finally
-                {
-                    this._releaseReply(_input);
-                }
-            }
-            else
-            {
-                org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("test",_opsClass);
-                if (_so == null)
-                   continue;
-                org.apache.activeio.oneport.openorb.TestIIOPServerOperations _self = (org.apache.activeio.oneport.openorb.TestIIOPServerOperations) _so.servant;
-                try
-                {
-                    _self.test();
-                    return;
-                }
-                finally
-                {
-                    _servant_postinvoke(_so);
-                }
-            }
-        }
-    }
-
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activeio.oneport.openorb;
+
+
+/**
+ * Interface definition: TestIIOPServer.
+ * 
+ * @author OpenORB Compiler
+ */
+public class _TestIIOPServerStub extends org.omg.CORBA.portable.ObjectImpl
+        implements TestIIOPServer
+{
+    static final String[] _ids_list =
+    {
+        "IDL:org/activeio/oneport/TestIIOPServer:1.0"
+    };
+
+    public String[] _ids()
+    {
+     return _ids_list;
+    }
+
+    private final static Class _opsClass = org.apache.activeio.oneport.openorb.TestIIOPServerOperations.class;
+
+    /**
+     * Operation test
+     */
+    public void test()
+    {
+        while(true)
+        {
+            if (!this._is_local())
+            {
+                org.omg.CORBA.portable.InputStream _input = null;
+                try
+                {
+                    org.omg.CORBA.portable.OutputStream _output = this._request("test",true);
+                    _input = this._invoke(_output);
+                    return;
+                }
+                catch(org.omg.CORBA.portable.RemarshalException _exception)
+                {
+                    continue;
+                }
+                catch(org.omg.CORBA.portable.ApplicationException _exception)
+                {
+                    String _exception_id = _exception.getId();
+                    throw new org.omg.CORBA.UNKNOWN("Unexpected User Exception: "+ _exception_id);
+                }
+                finally
+                {
+                    this._releaseReply(_input);
+                }
+            }
+            else
+            {
+                org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke("test",_opsClass);
+                if (_so == null)
+                   continue;
+                org.apache.activeio.oneport.openorb.TestIIOPServerOperations _self = (org.apache.activeio.oneport.openorb.TestIIOPServerOperations) _so.servant;
+                try
+                {
+                    _self.test();
+                    return;
+                }
+                finally
+                {
+                    _servant_postinvoke(_so);
+                }
+            }
+        }
+    }
+
+}

Propchange: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activeio/pom.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-console/pom.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/Main.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractAmqCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractAmqCommand.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractAmqCommand.java (original)
+++ incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractAmqCommand.java Tue Feb 21 15:12:56 2006
@@ -1,156 +1,156 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.console.command;
-
-import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.console.formatter.GlobalWriter;
-
-import javax.jms.ConnectionFactory;
-import javax.jms.Connection;
-import javax.jms.JMSException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Iterator;
-
-public abstract class AbstractAmqCommand extends AbstractCommand {
-    private URI brokerUrl;
-    private ConnectionFactory factory;
-    private final List connections = new ArrayList();
-
-    /**
-     * Establishes a connection to the remote broker specified by the broker url.
-     * @return - connection to the broker
-     * @throws JMSException
-     */
-    protected Connection createConnection() throws JMSException {
-        if (getBrokerUrl() == null) {
-            GlobalWriter.printException(new IllegalStateException("You must specify a broker URL to connect to using the --amqurl option."));
-            return null;
-        }
-
-        if (factory == null) {
-            factory = new ActiveMQConnectionFactory(getBrokerUrl());
-        }
-
-        Connection conn = factory.createConnection();
-        connections.add(conn);
-
-        return conn;
-    }
-
-    /**
-     * Establishes a connection to the remote broker specified by the broker url.
-     * @param username - username for the connection
-     * @param password - password for the connection
-     * @return - connection to the broker
-     * @throws JMSException
-     */
-    protected Connection createConnection(String username, String password) throws JMSException {
-        if (getBrokerUrl() == null) {
-            GlobalWriter.printException(new IllegalStateException("You must specify a broker URL to connect to using the --amqurl option."));
-            return null;
-        }
-
-        if (factory == null) {
-            factory = new ActiveMQConnectionFactory(getBrokerUrl());
-        }
-
-        Connection conn = factory.createConnection(username, password);
-        connections.add(conn);
-        conn.start();
-
-        return conn;
-    }
-
-    /**
-     * Close all created connections.
-     */
-    protected void closeAllConnections() {
-        for (Iterator i=connections.iterator(); i.hasNext();) {
-            try {
-                ((Connection)i.next()).close();
-            } catch (Exception e) { }
-        }
-
-        connections.clear();
-    }
-
-    /**
-     * Handle the --amqurl option.
-     * @param token - current option
-     * @param tokens - succeeding list of arguments
-     * @throws Exception
-     */
-    protected void handleOption(String token, List tokens) throws Exception {
-        // Try to handle the options first
-        if (token.equals("--amqurl")) {
-            // If no broker url specified, or next token is a new option
-            if (tokens.isEmpty() || ((String)tokens.get(0)).startsWith("-")) {
-                GlobalWriter.printException(new IllegalArgumentException("Broker URL not specified."));
-                tokens.clear();
-                return;
-            }
-
-            // If broker url already specified
-            if (getBrokerUrl() != null) {
-                GlobalWriter.printException(new IllegalArgumentException("Multiple broker URL cannot be specified."));
-                tokens.clear();
-                return;
-            }
-
-            String strBrokerUrl = (String)tokens.remove(0);
-
-            try {
-                setBrokerUrl(new URI(strBrokerUrl));
-            } catch (URISyntaxException e) {
-                GlobalWriter.printException(e);
-                tokens.clear();
-                return;
-            }
-        } else {
-            // Let the super class handle the option
-            super.handleOption(token, tokens);
-        }
-    }
-
-    /**
-     * Set the broker url.
-     * @param brokerUrl - new broker url
-     */
-    protected void setBrokerUrl(URI brokerUrl) {
-        this.brokerUrl = brokerUrl;
-    }
-
-    /**
-     * Set the broker url.
-     * @param address - address of the new broker url
-     * @throws URISyntaxException
-     */
-    protected void setBrokerUrl(String address) throws URISyntaxException {
-        this.brokerUrl = new URI(address);
-    }
-
-    /**
-     * Get the current broker url.
-     * @return current broker url
-     */
-    protected URI getBrokerUrl() {
-        return brokerUrl;
-    }
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.console.command;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.console.formatter.GlobalWriter;
+
+import javax.jms.ConnectionFactory;
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Iterator;
+
+public abstract class AbstractAmqCommand extends AbstractCommand {
+    private URI brokerUrl;
+    private ConnectionFactory factory;
+    private final List connections = new ArrayList();
+
+    /**
+     * Establishes a connection to the remote broker specified by the broker url.
+     * @return - connection to the broker
+     * @throws JMSException
+     */
+    protected Connection createConnection() throws JMSException {
+        if (getBrokerUrl() == null) {
+            GlobalWriter.printException(new IllegalStateException("You must specify a broker URL to connect to using the --amqurl option."));
+            return null;
+        }
+
+        if (factory == null) {
+            factory = new ActiveMQConnectionFactory(getBrokerUrl());
+        }
+
+        Connection conn = factory.createConnection();
+        connections.add(conn);
+
+        return conn;
+    }
+
+    /**
+     * Establishes a connection to the remote broker specified by the broker url.
+     * @param username - username for the connection
+     * @param password - password for the connection
+     * @return - connection to the broker
+     * @throws JMSException
+     */
+    protected Connection createConnection(String username, String password) throws JMSException {
+        if (getBrokerUrl() == null) {
+            GlobalWriter.printException(new IllegalStateException("You must specify a broker URL to connect to using the --amqurl option."));
+            return null;
+        }
+
+        if (factory == null) {
+            factory = new ActiveMQConnectionFactory(getBrokerUrl());
+        }
+
+        Connection conn = factory.createConnection(username, password);
+        connections.add(conn);
+        conn.start();
+
+        return conn;
+    }
+
+    /**
+     * Close all created connections.
+     */
+    protected void closeAllConnections() {
+        for (Iterator i=connections.iterator(); i.hasNext();) {
+            try {
+                ((Connection)i.next()).close();
+            } catch (Exception e) { }
+        }
+
+        connections.clear();
+    }
+
+    /**
+     * Handle the --amqurl option.
+     * @param token - current option
+     * @param tokens - succeeding list of arguments
+     * @throws Exception
+     */
+    protected void handleOption(String token, List tokens) throws Exception {
+        // Try to handle the options first
+        if (token.equals("--amqurl")) {
+            // If no broker url specified, or next token is a new option
+            if (tokens.isEmpty() || ((String)tokens.get(0)).startsWith("-")) {
+                GlobalWriter.printException(new IllegalArgumentException("Broker URL not specified."));
+                tokens.clear();
+                return;
+            }
+
+            // If broker url already specified
+            if (getBrokerUrl() != null) {
+                GlobalWriter.printException(new IllegalArgumentException("Multiple broker URL cannot be specified."));
+                tokens.clear();
+                return;
+            }
+
+            String strBrokerUrl = (String)tokens.remove(0);
+
+            try {
+                setBrokerUrl(new URI(strBrokerUrl));
+            } catch (URISyntaxException e) {
+                GlobalWriter.printException(e);
+                tokens.clear();
+                return;
+            }
+        } else {
+            // Let the super class handle the option
+            super.handleOption(token, tokens);
+        }
+    }
+
+    /**
+     * Set the broker url.
+     * @param brokerUrl - new broker url
+     */
+    protected void setBrokerUrl(URI brokerUrl) {
+        this.brokerUrl = brokerUrl;
+    }
+
+    /**
+     * Set the broker url.
+     * @param address - address of the new broker url
+     * @throws URISyntaxException
+     */
+    protected void setBrokerUrl(String address) throws URISyntaxException {
+        this.brokerUrl = new URI(address);
+    }
+
+    /**
+     * Get the current broker url.
+     * @return current broker url
+     */
+    protected URI getBrokerUrl() {
+        return brokerUrl;
+    }
+}

Propchange: incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractAmqCommand.java
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractCommand.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractCommand.java?rev=379619&r1=379618&r2=379619&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractCommand.java (original)
+++ incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractCommand.java Tue Feb 21 15:12:56 2006
@@ -1,120 +1,120 @@
-/**
- *
- * Copyright 2005-2006 The Apache Software Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.console.command;
-
-import org.apache.activemq.ActiveMQConnectionMetaData;
-import org.apache.activemq.console.formatter.GlobalWriter;
-
-import java.util.List;
-
-public abstract class AbstractCommand implements Command {
-    public static final String COMMAND_OPTION_DELIMETER = ",";
-
-    private boolean isPrintHelp    = false;
-    private boolean isPrintVersion = false;
-
-    /**
-     * Exceute a generic command, which includes parsing the options for the command and running the specific task.
-     * @param tokens - command arguments
-     * @throws Exception
-     */
-    public void execute(List tokens) throws Exception {
-        // Parse the options specified by "-"
-        parseOptions(tokens);
-
-        // Print the help file of the task
-        if (isPrintHelp) {
-            printHelp();
-
-        // Print the AMQ version
-        } else if (isPrintVersion) {
-            GlobalWriter.printVersion(ActiveMQConnectionMetaData.PROVIDER_VERSION);
-
-        // Run the specified task
-        } else {
-            runTask(tokens);
-        }
-    }
-
-    /**
-     * Parse any option parameters in the command arguments specified by a '-' as the first character of the token.
-     * @param tokens - command arguments
-     * @throws Exception
-     */
-    protected void parseOptions(List tokens) throws Exception {
-        while (!tokens.isEmpty()) {
-            String token = (String)tokens.remove(0);
-            if (token.startsWith("-")) {
-                // Token is an option
-                handleOption(token, tokens);
-            } else {
-                // Push back to list of tokens
-                tokens.add(0, token);
-                return;
-            }
-        }
-    }
-
-    /**
-     * Handle the general options for each command, which includes -h, -?, --help, -D, --version.
-     * @param token - option token to handle
-     * @param tokens - succeeding command arguments
-     * @throws Exception
-     */
-    protected void handleOption(String token, List tokens) throws Exception {
-        // If token is a help option
-        if (token.equals("-h") || token.equals("-?") || token.equals("--help")) {
-            isPrintHelp = true;
-            tokens.clear();
-
-        // If token is a version option
-        } else if (token.equals("--version")) {
-            isPrintVersion = true;
-            tokens.clear();
-        }
-
-        // If token is a system property define option
-        else if (token.startsWith("-D")) {
-            String key = token.substring(2);
-            String value = "";
-            int pos = key.indexOf("=");
-            if (pos >= 0) {
-                value = key.substring(pos + 1);
-                key = key.substring(0, pos);
-            }
-            System.setProperty(key, value);
-
-        }
-
-        // Token is unrecognized
-        else {
-            GlobalWriter.printInfo("Ignoring unrecognized option: " + token);
-        }
-    }
-
-    /**
-     * Run the specific task.
-     * @param tokens - command arguments
-     * @throws Exception
-     */
-    abstract protected void runTask(List tokens) throws Exception;
-
-    /**
-     * Print the help messages for the specific task
-     */
-    abstract protected void printHelp();
-}
+/**
+ *
+ * Copyright 2005-2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.console.command;
+
+import org.apache.activemq.ActiveMQConnectionMetaData;
+import org.apache.activemq.console.formatter.GlobalWriter;
+
+import java.util.List;
+
+public abstract class AbstractCommand implements Command {
+    public static final String COMMAND_OPTION_DELIMETER = ",";
+
+    private boolean isPrintHelp    = false;
+    private boolean isPrintVersion = false;
+
+    /**
+     * Exceute a generic command, which includes parsing the options for the command and running the specific task.
+     * @param tokens - command arguments
+     * @throws Exception
+     */
+    public void execute(List tokens) throws Exception {
+        // Parse the options specified by "-"
+        parseOptions(tokens);
+
+        // Print the help file of the task
+        if (isPrintHelp) {
+            printHelp();
+
+        // Print the AMQ version
+        } else if (isPrintVersion) {
+            GlobalWriter.printVersion(ActiveMQConnectionMetaData.PROVIDER_VERSION);
+
+        // Run the specified task
+        } else {
+            runTask(tokens);
+        }
+    }
+
+    /**
+     * Parse any option parameters in the command arguments specified by a '-' as the first character of the token.
+     * @param tokens - command arguments
+     * @throws Exception
+     */
+    protected void parseOptions(List tokens) throws Exception {
+        while (!tokens.isEmpty()) {
+            String token = (String)tokens.remove(0);
+            if (token.startsWith("-")) {
+                // Token is an option
+                handleOption(token, tokens);
+            } else {
+                // Push back to list of tokens
+                tokens.add(0, token);
+                return;
+            }
+        }
+    }
+
+    /**
+     * Handle the general options for each command, which includes -h, -?, --help, -D, --version.
+     * @param token - option token to handle
+     * @param tokens - succeeding command arguments
+     * @throws Exception
+     */
+    protected void handleOption(String token, List tokens) throws Exception {
+        // If token is a help option
+        if (token.equals("-h") || token.equals("-?") || token.equals("--help")) {
+            isPrintHelp = true;
+            tokens.clear();
+
+        // If token is a version option
+        } else if (token.equals("--version")) {
+            isPrintVersion = true;
+            tokens.clear();
+        }
+
+        // If token is a system property define option
+        else if (token.startsWith("-D")) {
+            String key = token.substring(2);
+            String value = "";
+            int pos = key.indexOf("=");
+            if (pos >= 0) {
+                value = key.substring(pos + 1);
+                key = key.substring(0, pos);
+            }
+            System.setProperty(key, value);
+
+        }
+
+        // Token is unrecognized
+        else {
+            GlobalWriter.printInfo("Ignoring unrecognized option: " + token);
+        }
+    }
+
+    /**
+     * Run the specific task.
+     * @param tokens - command arguments
+     * @throws Exception
+     */
+    abstract protected void runTask(List tokens) throws Exception;
+
+    /**
+     * Print the help messages for the specific task
+     */
+    abstract protected void printHelp();
+}

Propchange: incubator/activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/command/AbstractCommand.java
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message