activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r358673 - in /incubator/activemq/trunk/activeio: activeio-core/ activeio-core/src/main/java/org/apache/activeio/oneport/openorb/ activeio-core/src/test/java/org/apache/activeio/oneport/openorb/ activeio-core/src/test/java/org/apache/activei...
Date Fri, 23 Dec 2005 01:12:49 GMT
Author: chirino
Date: Thu Dec 22 17:12:34 2005
New Revision: 358673

URL: http://svn.apache.org/viewcvs?rev=358673&view=rev
Log:
Refactored the openorb oneport adatper into it's own little build module

Added:
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/.classpath
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/.project
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/.settings/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/.settings/org.eclipse.jdt.core.prefs
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/.wtpmodules
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/LICENSE.txt
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/pom.xml
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/resources/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.idl
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java
    incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/resources/
Removed:
    incubator/activemq/trunk/activeio/activeio-core/maven.xml
    incubator/activemq/trunk/activeio/activeio-core/project.properties
    incubator/activemq/trunk/activeio/activeio-core/project.xml
    incubator/activemq/trunk/activeio/activeio-core/src/main/java/org/apache/activeio/oneport/openorb/
    incubator/activemq/trunk/activeio/activeio-core/src/test/java/org/apache/activeio/oneport/openorb/
Modified:
    incubator/activemq/trunk/activeio/activeio-core/pom.xml
    incubator/activemq/trunk/activeio/activeio-core/src/test/java/org/apache/activeio/packet/sync/ssl/SslSocketSynchChannelTest.java

Modified: incubator/activemq/trunk/activeio/activeio-core/pom.xml
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/pom.xml?rev=358673&r1=358672&r2=358673&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/pom.xml (original)
+++ incubator/activemq/trunk/activeio/activeio-core/pom.xml Thu Dec 22 17:12:34 2005
@@ -45,38 +45,6 @@
       <version>5.1.2</version>
     </dependency>
     
-    <!-- For OpenORB integration -->
-    <dependency>
-      <groupId>openorb</groupId>
-      <artifactId>openorb-orb</artifactId>
-      <version>1.4.0-GERONIMO</version>
-    </dependency>
-    <dependency>
-      <groupId>openorb</groupId>
-      <artifactId>openorb-tools</artifactId>
-      <version>1.4.0-GERONIMO</version>
-    </dependency>
-    <dependency>
-      <groupId>openorb</groupId>
-      <artifactId>openorb-orb-tools</artifactId>
-      <version>1.4.0-GERONIMO</version>
-    </dependency>
-    <dependency>
-      <groupId>openorb</groupId>
-      <artifactId>openorb-orb-omg</artifactId>
-      <version>1.4.0-GERONIMO</version>
-    </dependency>
-    <dependency>
-      <groupId>avalon</groupId>
-      <artifactId>avalon-framework</artifactId>
-      <version>4.1.4</version>
-    </dependency>
-    <dependency>
-      <groupId>avalon</groupId>
-      <artifactId>avalon-logkit</artifactId>
-      <version>1.2.2</version>
-    </dependency>
-
     <!-- Unit Test Dependencies -->
     <dependency>
       <groupId>junit</groupId>
@@ -128,5 +96,20 @@
     </dependency>
     
   </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <artifactId>maven-jar-plugin</artifactId>
+        <executions>
+          <execution>
+            <goals>
+              <goal>test-jar</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
 
 </project>

Modified: incubator/activemq/trunk/activeio/activeio-core/src/test/java/org/apache/activeio/packet/sync/ssl/SslSocketSynchChannelTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-core/src/test/java/org/apache/activeio/packet/sync/ssl/SslSocketSynchChannelTest.java?rev=358673&r1=358672&r2=358673&view=diff
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-core/src/test/java/org/apache/activeio/packet/sync/ssl/SslSocketSynchChannelTest.java (original)
+++ incubator/activemq/trunk/activeio/activeio-core/src/test/java/org/apache/activeio/packet/sync/ssl/SslSocketSynchChannelTest.java Thu Dec 22 17:12:34 2005
@@ -32,10 +32,10 @@
 
     static {
         String basedir = System.getProperty("basedir");
-        System.setProperty("javax.net.ssl.trustStore", basedir+"/src/test/client.keystore");
+        System.setProperty("javax.net.ssl.trustStore", basedir+"/src/test/resources/client.keystore");
         System.setProperty("javax.net.ssl.trustStorePassword", "password");
         System.setProperty("javax.net.ssl.trustStoreType", "jks");        
-        System.setProperty("javax.net.ssl.keyStore", basedir+"/src/test/server.keystore");
+        System.setProperty("javax.net.ssl.keyStore", basedir+"/src/test/resources/server.keystore");
         System.setProperty("javax.net.ssl.keyStorePassword", "password");
         System.setProperty("javax.net.ssl.keyStoreType", "jks");        
         //System.setProperty("javax.net.debug", "ssl,handshake,data,trustmanager");        

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/.classpath
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/.classpath?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/.classpath (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/.classpath Thu Dec 22 17:12:34 2005
@@ -0,0 +1,20 @@
+<classpath>
+  <classpathentry kind="src" path="src/main/java"/>
+  <classpathentry kind="src" path="src/main/resources"/>
+  <classpathentry kind="src" path="src/test/java" output="target/test-classes"/>
+  <classpathentry kind="src" path="src/test/resources" output="target/test-classes"/>
+  <classpathentry kind="output" path="target/classes"/>
+  <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+  <classpathentry kind="var" path="M2_REPO/openorb/openorb-tools/1.4.0-GERONIMO/openorb-tools-1.4.0-GERONIMO.jar"/>
+  <classpathentry kind="var" path="M2_REPO/backport-util-concurrent/backport-util-concurrent/2.0_01_pd/backport-util-concurrent-2.0_01_pd.jar"/>
+  <classpathentry kind="var" path="M2_REPO/junit/junit/3.8.1/junit-3.8.1.jar"/>
+  <classpathentry kind="var" path="M2_REPO/openorb/openorb-orb-tools/1.4.0-GERONIMO/openorb-orb-tools-1.4.0-GERONIMO.jar"/>
+  <classpathentry kind="var" path="M2_REPO/org/apache/activeio/activeio-core/3.0-SNAPSHOT/activeio-core-3.0-SNAPSHOT.jar"/>
+  <classpathentry kind="var" path="M2_REPO/commons-logging/commons-logging/1.0.4/commons-logging-1.0.4.jar"/>
+  <classpathentry kind="var" path="M2_REPO/log4j/log4j/1.2.8/log4j-1.2.8.jar"/>
+  <classpathentry kind="var" path="M2_REPO/avalon/avalon-framework/4.1.4/avalon-framework-4.1.4.jar"/>
+  <classpathentry kind="var" path="M2_REPO/avalon/avalon-logkit/1.2.2/avalon-logkit-1.2.2.jar"/>
+  <classpathentry kind="var" path="M2_REPO/openorb/openorb-orb/1.4.0-GERONIMO/openorb-orb-1.4.0-GERONIMO.jar"/>
+  <classpathentry kind="var" path="M2_REPO/org/apache/activeio/activeio-core/3.0-SNAPSHOT/activeio-core-3.0-SNAPSHOT-tests.jar"/>
+  <classpathentry kind="var" path="M2_REPO/openorb/openorb-orb-omg/1.4.0-GERONIMO/openorb-orb-omg-1.4.0-GERONIMO.jar"/>
+</classpath>
\ No newline at end of file

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/.project
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/.project?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/.project (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/.project Thu Dec 22 17:12:34 2005
@@ -0,0 +1,28 @@
+<projectDescription>
+  <name>activeio-oneport-openorb</name>
+  <comment>A Openport OpenORB adapter</comment>
+  <projects/>
+  <buildSpec>
+    <buildCommand>
+      <name>org.eclipse.wst.common.modulecore.ComponentStructuralBuilder</name>
+      <arguments/>
+    </buildCommand>
+    <buildCommand>
+      <name>org.eclipse.jdt.core.javabuilder</name>
+      <arguments/>
+    </buildCommand>
+    <buildCommand>
+      <name>org.eclipse.wst.validation.validationbuilder</name>
+      <arguments/>
+    </buildCommand>
+    <buildCommand>
+      <name>org.eclipse.wst.common.modulecore.ComponentStructuralBuilderDependencyResolver</name>
+      <arguments/>
+    </buildCommand>
+  </buildSpec>
+  <natures>
+    <nature>org.eclipse.jem.workbench.JavaEMFNature</nature>
+    <nature>org.eclipse.jdt.core.javanature</nature>
+    <nature>org.eclipse.wst.common.modulecore.ModuleCoreNature</nature>
+  </natures>
+</projectDescription>
\ No newline at end of file

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/.settings/org.eclipse.jdt.core.prefs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/.settings/org.eclipse.jdt.core.prefs?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/.settings/org.eclipse.jdt.core.prefs (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/.settings/org.eclipse.jdt.core.prefs Thu Dec 22 17:12:34 2005
@@ -0,0 +1,5 @@
+#Tue Dec 22 19:33:47 EST 2037
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.4
+org.eclipse.jdt.core.compiler.compliance=1.4
+org.eclipse.jdt.core.compiler.source=1.4

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/.wtpmodules
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/.wtpmodules?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/.wtpmodules (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/.wtpmodules Thu Dec 22 17:12:34 2005
@@ -0,0 +1,9 @@
+<project-modules id="moduleCoreId">
+  <wb-module deploy-name="activeio-oneport-openorb">
+    <module-type module-type-id="jst.utility">
+      <property name="java-output-path" value="/target/classes"/>
+    </module-type>
+    <wb-resource deploy-path="/" source-path="src/main/java"/>
+    <wb-resource deploy-path="/" source-path="src/main/resources"/>
+  </wb-module>
+</project-modules>
\ No newline at end of file

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/LICENSE.txt
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/LICENSE.txt?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/LICENSE.txt (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/LICENSE.txt Thu Dec 22 17:12:34 2005
@@ -0,0 +1,203 @@
+
+                                 Apache License
+                           Version 2.0, January 2004
+                        http://www.apache.org/licenses/
+
+   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+   1. Definitions.
+
+      "License" shall mean the terms and conditions for use, reproduction,
+      and distribution as defined by Sections 1 through 9 of this document.
+
+      "Licensor" shall mean the copyright owner or entity authorized by
+      the copyright owner that is granting the License.
+
+      "Legal Entity" shall mean the union of the acting entity and all
+      other entities that control, are controlled by, or are under common
+      control with that entity. For the purposes of this definition,
+      "control" means (i) the power, direct or indirect, to cause the
+      direction or management of such entity, whether by contract or
+      otherwise, or (ii) ownership of fifty percent (50%) or more of the
+      outstanding shares, or (iii) beneficial ownership of such entity.
+
+      "You" (or "Your") shall mean an individual or Legal Entity
+      exercising permissions granted by this License.
+
+      "Source" form shall mean the preferred form for making modifications,
+      including but not limited to software source code, documentation
+      source, and configuration files.
+
+      "Object" form shall mean any form resulting from mechanical
+      transformation or translation of a Source form, including but
+      not limited to compiled object code, generated documentation,
+      and conversions to other media types.
+
+      "Work" shall mean the work of authorship, whether in Source or
+      Object form, made available under the License, as indicated by a
+      copyright notice that is included in or attached to the work
+      (an example is provided in the Appendix below).
+
+      "Derivative Works" shall mean any work, whether in Source or Object
+      form, that is based on (or derived from) the Work and for which the
+      editorial revisions, annotations, elaborations, or other modifications
+      represent, as a whole, an original work of authorship. For the purposes
+      of this License, Derivative Works shall not include works that remain
+      separable from, or merely link (or bind by name) to the interfaces of,
+      the Work and Derivative Works thereof.
+
+      "Contribution" shall mean any work of authorship, including
+      the original version of the Work and any modifications or additions
+      to that Work or Derivative Works thereof, that is intentionally
+      submitted to Licensor for inclusion in the Work by the copyright owner
+      or by an individual or Legal Entity authorized to submit on behalf of
+      the copyright owner. For the purposes of this definition, "submitted"
+      means any form of electronic, verbal, or written communication sent
+      to the Licensor or its representatives, including but not limited to
+      communication on electronic mailing lists, source code control systems,
+      and issue tracking systems that are managed by, or on behalf of, the
+      Licensor for the purpose of discussing and improving the Work, but
+      excluding communication that is conspicuously marked or otherwise
+      designated in writing by the copyright owner as "Not a Contribution."
+
+      "Contributor" shall mean Licensor and any individual or Legal Entity
+      on behalf of whom a Contribution has been received by Licensor and
+      subsequently incorporated within the Work.
+
+   2. Grant of Copyright License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      copyright license to reproduce, prepare Derivative Works of,
+      publicly display, publicly perform, sublicense, and distribute the
+      Work and such Derivative Works in Source or Object form.
+
+   3. Grant of Patent License. Subject to the terms and conditions of
+      this License, each Contributor hereby grants to You a perpetual,
+      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+      (except as stated in this section) patent license to make, have made,
+      use, offer to sell, sell, import, and otherwise transfer the Work,
+      where such license applies only to those patent claims licensable
+      by such Contributor that are necessarily infringed by their
+      Contribution(s) alone or by combination of their Contribution(s)
+      with the Work to which such Contribution(s) was submitted. If You
+      institute patent litigation against any entity (including a
+      cross-claim or counterclaim in a lawsuit) alleging that the Work
+      or a Contribution incorporated within the Work constitutes direct
+      or contributory patent infringement, then any patent licenses
+      granted to You under this License for that Work shall terminate
+      as of the date such litigation is filed.
+
+   4. Redistribution. You may reproduce and distribute copies of the
+      Work or Derivative Works thereof in any medium, with or without
+      modifications, and in Source or Object form, provided that You
+      meet the following conditions:
+
+      (a) You must give any other recipients of the Work or
+          Derivative Works a copy of this License; and
+
+      (b) You must cause any modified files to carry prominent notices
+          stating that You changed the files; and
+
+      (c) You must retain, in the Source form of any Derivative Works
+          that You distribute, all copyright, patent, trademark, and
+          attribution notices from the Source form of the Work,
+          excluding those notices that do not pertain to any part of
+          the Derivative Works; and
+
+      (d) If the Work includes a "NOTICE" text file as part of its
+          distribution, then any Derivative Works that You distribute must
+          include a readable copy of the attribution notices contained
+          within such NOTICE file, excluding those notices that do not
+          pertain to any part of the Derivative Works, in at least one
+          of the following places: within a NOTICE text file distributed
+          as part of the Derivative Works; within the Source form or
+          documentation, if provided along with the Derivative Works; or,
+          within a display generated by the Derivative Works, if and
+          wherever such third-party notices normally appear. The contents
+          of the NOTICE file are for informational purposes only and
+          do not modify the License. You may add Your own attribution
+          notices within Derivative Works that You distribute, alongside
+          or as an addendum to the NOTICE text from the Work, provided
+          that such additional attribution notices cannot be construed
+          as modifying the License.
+
+      You may add Your own copyright statement to Your modifications and
+      may provide additional or different license terms and conditions
+      for use, reproduction, or distribution of Your modifications, or
+      for any such Derivative Works as a whole, provided Your use,
+      reproduction, and distribution of the Work otherwise complies with
+      the conditions stated in this License.
+
+   5. Submission of Contributions. Unless You explicitly state otherwise,
+      any Contribution intentionally submitted for inclusion in the Work
+      by You to the Licensor shall be under the terms and conditions of
+      this License, without any additional terms or conditions.
+      Notwithstanding the above, nothing herein shall supersede or modify
+      the terms of any separate license agreement you may have executed
+      with Licensor regarding such Contributions.
+
+   6. Trademarks. This License does not grant permission to use the trade
+      names, trademarks, service marks, or product names of the Licensor,
+      except as required for reasonable and customary use in describing the
+      origin of the Work and reproducing the content of the NOTICE file.
+
+   7. Disclaimer of Warranty. Unless required by applicable law or
+      agreed to in writing, Licensor provides the Work (and each
+      Contributor provides its Contributions) on an "AS IS" BASIS,
+      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+      implied, including, without limitation, any warranties or conditions
+      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+      PARTICULAR PURPOSE. You are solely responsible for determining the
+      appropriateness of using or redistributing the Work and assume any
+      risks associated with Your exercise of permissions under this License.
+
+   8. Limitation of Liability. In no event and under no legal theory,
+      whether in tort (including negligence), contract, or otherwise,
+      unless required by applicable law (such as deliberate and grossly
+      negligent acts) or agreed to in writing, shall any Contributor be
+      liable to You for damages, including any direct, indirect, special,
+      incidental, or consequential damages of any character arising as a
+      result of this License or out of the use or inability to use the
+      Work (including but not limited to damages for loss of goodwill,
+      work stoppage, computer failure or malfunction, or any and all
+      other commercial damages or losses), even if such Contributor
+      has been advised of the possibility of such damages.
+
+   9. Accepting Warranty or Additional Liability. While redistributing
+      the Work or Derivative Works thereof, You may choose to offer,
+      and charge a fee for, acceptance of support, warranty, indemnity,
+      or other liability obligations and/or rights consistent with this
+      License. However, in accepting such obligations, You may act only
+      on Your own behalf and on Your sole responsibility, not on behalf
+      of any other Contributor, and only if You agree to indemnify,
+      defend, and hold each Contributor harmless for any liability
+      incurred by, or claims asserted against, such Contributor by reason
+      of your accepting any such warranty or additional liability.
+
+   END OF TERMS AND CONDITIONS
+
+   APPENDIX: How to apply the Apache License to your work.
+
+      To apply the Apache License to your work, attach the following
+      boilerplate notice, with the fields enclosed by brackets "[]"
+      replaced with your own identifying information. (Don't include
+      the brackets!)  The text should be enclosed in the appropriate
+      comment syntax for the file format. We also recommend that a
+      file or class name and description of purpose be included on the
+      same "printed page" as the copyright notice for easier
+      identification within third-party archives.
+
+   Copyright [yyyy] [name of copyright owner]
+
+   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.
+

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/pom.xml
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/pom.xml?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/pom.xml (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/pom.xml Thu Dec 22 17:12:34 2005
@@ -0,0 +1,83 @@
+<project>
+
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.apache.activeio</groupId>
+    <artifactId>activeio-project</artifactId>
+    <relativePath>../pom.xml</relativePath>
+    <version>3.0-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>activeio-oneport-openorb</artifactId>
+  <name>ActiveIO :: Openport :: OpenORB</name>
+  <description>A Openport OpenORB adapter</description>
+  
+  <dependencies>
+    <!-- Required Dependencies -->
+
+    <dependency>
+      <groupId>org.apache.activeio</groupId>
+      <artifactId>activeio-core</artifactId>
+      <version>${version}</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activeio</groupId>
+      <artifactId>activeio-core</artifactId>
+      <version>${version}</version>
+      <type>test-jar</type>
+    </dependency>
+    
+    <dependency>
+      <groupId>backport-util-concurrent</groupId>
+      <artifactId>backport-util-concurrent</artifactId>
+    </dependency>
+
+    <!-- For OpenORB integration -->
+    <dependency>
+      <groupId>openorb</groupId>
+      <artifactId>openorb-orb</artifactId>
+      <version>1.4.0-GERONIMO</version>
+    </dependency>
+    <dependency>
+      <groupId>openorb</groupId>
+      <artifactId>openorb-tools</artifactId>
+      <version>1.4.0-GERONIMO</version>
+    </dependency>
+    <dependency>
+      <groupId>openorb</groupId>
+      <artifactId>openorb-orb-tools</artifactId>
+      <version>1.4.0-GERONIMO</version>
+    </dependency>
+    <dependency>
+      <groupId>openorb</groupId>
+      <artifactId>openorb-orb-omg</artifactId>
+      <version>1.4.0-GERONIMO</version>
+    </dependency>
+    <dependency>
+      <groupId>avalon</groupId>
+      <artifactId>avalon-framework</artifactId>
+      <version>4.1.4</version>
+    </dependency>
+    <dependency>
+      <groupId>avalon</groupId>
+      <artifactId>avalon-logkit</artifactId>
+      <version>1.2.2</version>
+    </dependency>
+
+    <!-- Unit Test Dependencies -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>commons-logging</groupId>
+      <artifactId>commons-logging</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>log4j</groupId>
+      <artifactId>log4j</artifactId>
+    </dependency>
+
+  </dependencies>
+
+</project>

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortFeatureInitializer.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,40 @@
+/**
+ *
+ * Copyright 2004 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);                    
+        }
+    }
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/main/java/org/apache/activeio/oneport/openorb/OpenORBOpenPortSocketFactory.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,58 @@
+/**
+ *
+ * Copyright 2004 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);
+    }
+    
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/OpenORBOnePortSocketFactoryTest.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,90 @@
+/**
+ *
+ * Copyright 2004 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);
+        }
+    }
+                    
+}

Added: incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.idl
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.idl?rev=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.idl (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.idl Thu Dec 22 17:12:34 2005
@@ -0,0 +1,32 @@
+/**
+ * 
+ * Copyright 2004 Hiram Chirino
+ * 
+ * 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. 
+ * 
+ **/
+ 
+module org
+{
+    module activeio
+    {
+        module oneport
+        {
+            interface TestIIOPServer
+            {
+                void test();
+            };
+        };
+    };
+};
+

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServer.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,26 @@
+/**
+ *
+ * Copyright 2004 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
+{
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHelper.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,148 @@
+/**
+ *
+ * Copyright 2004 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;
+
+    }
+
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerHolder.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,74 @@
+/**
+ *
+ * Copyright 2004 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();
+    }
+
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerImpl.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,32 @@
+
+/**
+ *
+ * Copyright 2004 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) {
+        }
+    }
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerOperations.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,31 @@
+/**
+ *
+ * Copyright 2004 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();
+
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOA.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,72 @@
+/**
+ *
+ * Copyright 2004 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;
+    }
+
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/TestIIOPServerPOATie.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,89 @@
+/**
+ *
+ * Copyright 2004 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();
+    }
+
+}

Added: 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=358673&view=auto
==============================================================================
--- incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java (added)
+++ incubator/activemq/trunk/activeio/activeio-oneport-openorb/src/test/java/org/apache/activeio/oneport/openorb/_TestIIOPServerStub.java Thu Dec 22 17:12:34 2005
@@ -0,0 +1,89 @@
+/**
+ *
+ * Copyright 2004 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);
+                }
+            }
+        }
+    }
+
+}



Mime
View raw message