From 5963a2d3d6860fe57afc138f095bf2d2eb5a7b80 Mon Sep 17 00:00:00 2001 From: lresende Date: Mon, 7 Oct 2013 22:23:21 +0000 Subject: Official Tuscany 2.0.1 Release git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1530096 13f79535-47bb-0310-9956-ffa450edef68 --- .../testing/itest/policy/reliability/pom.xml | 57 ----------- .../src/main/java/helloworld/HelloWorld.java | 31 ------ .../src/main/java/helloworld/HelloWorldClient.java | 48 --------- .../main/java/helloworld/HelloWorldException.java | 34 ------- .../main/java/helloworld/HelloWorldService.java | 42 -------- .../src/main/java/helloworld/StatusImpl.java | 32 ------ .../TestBindingWSAxisHandler.java | 45 --------- .../testbindingwspolicy/TestBindingWSPolicy.java | 63 ------------ .../TestBindingWSPolicyBuilder.java | 84 ---------------- .../TestBindingWSPolicyInterceptor.java | 84 ---------------- .../TestBindingWSPolicyProcessor.java | 99 ------------------- .../TestBindingWSPolicyProviderFactory.java | 69 ------------- .../TestBindingWSPolicyProviderReference.java | 72 -------------- .../TestBindingWSPolicyProviderService.java | 72 -------------- .../src/main/java/testpolicy/TestPolicy.java | 63 ------------ .../main/java/testpolicy/TestPolicyBuilder.java | 84 ---------------- .../java/testpolicy/TestPolicyInterceptor.java | 110 --------------------- .../main/java/testpolicy/TestPolicyProcessor.java | 99 ------------------- .../java/testpolicy/TestPolicyProviderFactory.java | 68 ------------- .../TestPolicyProviderImplementation.java | 56 ----------- .../testpolicy/TestPolicyProviderReference.java | 53 ---------- .../java/testpolicy/TestPolicyProviderService.java | 53 ---------- .../main/resources/META-INF/sca-contribution.xml | 23 ----- ...ache.tuscany.sca.assembly.builder.PolicyBuilder | 18 ---- ...ca.contribution.processor.StAXArtifactProcessor | 21 ---- ....apache.tuscany.sca.definitions.xml.Definitions | 17 ---- ...ache.tuscany.sca.provider.PolicyProviderFactory | 21 ---- .../reliability/src/main/resources/definitions.xml | 48 --------- .../src/main/resources/helloworld.composite | 40 -------- .../reliability/src/main/resources/helloworld.wsdl | 90 ----------------- .../test/java/interceptors/HelloworldTestCase.java | 87 ---------------- 31 files changed, 1783 deletions(-) delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/pom.xml delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorld.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldClient.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldException.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldService.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/StatusImpl.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSAxisHandler.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicy.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyBuilder.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyInterceptor.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProcessor.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderFactory.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderReference.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderService.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicy.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyBuilder.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyInterceptor.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProcessor.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderFactory.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderImplementation.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderReference.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderService.java delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/sca-contribution.xml delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/definitions.xml delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.composite delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.wsdl delete mode 100644 sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/test/java/interceptors/HelloworldTestCase.java (limited to 'sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability') diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/pom.xml b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/pom.xml deleted file mode 100644 index a6cdaa8975..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/pom.xml +++ /dev/null @@ -1,57 +0,0 @@ - - - - 4.0.0 - - org.apache.tuscany.sca - itest-policy - 2.0.1 - ../pom.xml - - - itest-policy-reliability - Apache Tuscany SCA iTest Policy Reliability - - - - - org.apache.tuscany.sca - tuscany-base-runtime-pom - pom - 2.0.1 - - - - org.apache.tuscany.sca - tuscany-binding-ws-runtime-axis2 - 2.0.1 - - - - org.mortbay.jetty - jetty - 6.1.19 - - - - - ${project.artifactId} - - diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorld.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorld.java deleted file mode 100644 index 1f5b8b365d..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorld.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 helloworld; - -import org.oasisopen.sca.annotation.Remotable; - -@Remotable -public interface HelloWorld { - - String getGreetings(String s); - - String getGreetingsException(String s) throws HelloWorldException; - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldClient.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldClient.java deleted file mode 100644 index baeea9bb4b..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldClient.java +++ /dev/null @@ -1,48 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 helloworld; - -import org.oasisopen.sca.annotation.Reference; -import org.oasisopen.sca.annotation.Requires; - -public class HelloWorldClient implements HelloWorld { - - @Reference - public HelloWorld helloWorldWS; - - public String getGreetings(String s) { - StatusImpl.appendStatus("At client.getGreetings() pre-invoke", s); - String response = helloWorldWS.getGreetings(s); - StatusImpl.appendStatus("At client.getGreetings() post-invoke", response); - return response; - } - - public String getGreetingsException(String s) throws HelloWorldException { - StatusImpl.appendStatus("At client.getGreetingsException() pre-invoke", s); - try { - String response = helloWorldWS.getGreetingsException(s); - StatusImpl.appendStatus("At client.getGreetingsException() post-invoke", response); - return response; - } catch (HelloWorldException ex){ - StatusImpl.appendStatus("At client.getGreetingsException() post-exception", ex.getMessage()); - throw ex; - } - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldException.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldException.java deleted file mode 100644 index b4a9fec640..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldException.java +++ /dev/null @@ -1,34 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 helloworld; - - -public class HelloWorldException extends Exception { - - private static final long serialVersionUID = 4608283774062947117L; - - public HelloWorldException(){ - } - - public HelloWorldException(String message){ - super(message); - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldService.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldService.java deleted file mode 100644 index e4fb70af09..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/HelloWorldService.java +++ /dev/null @@ -1,42 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 helloworld; - -import org.oasisopen.sca.RequestContext; -import org.oasisopen.sca.annotation.Context; - -public class HelloWorldService implements HelloWorld { - - @Context - protected RequestContext requestContext; - - public String getGreetings(String s) { - //Subject subject = requestContext.getSecuritySubject(); - String response = "Hello " + s; - StatusImpl.appendStatus("At service.getGreetings()", response); - return response; - } - - public String getGreetingsException(String s) throws HelloWorldException { - String response = "Hello " + s; - StatusImpl.appendStatus("At service.getGreetingsException()", response); - throw new HelloWorldException(response); - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/StatusImpl.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/StatusImpl.java deleted file mode 100644 index 644853d6c2..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/helloworld/StatusImpl.java +++ /dev/null @@ -1,32 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 helloworld; - -public class StatusImpl { - - public static String statusString = ""; - - public static void appendStatus(String event, String location){ - // remove any addresses from the strings - location = location.replaceAll("\\(@.*Endpoint", "Endpoint"); - statusString += event + " - " + location + "\n"; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSAxisHandler.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSAxisHandler.java deleted file mode 100644 index 686866e12d..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSAxisHandler.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import helloworld.StatusImpl; - -import org.apache.axis2.AxisFault; -import org.apache.axis2.context.MessageContext; -import org.apache.axis2.handlers.AbstractHandler; - -/** - * An Axis handler to show that policy can add one of needs be - * - * @version $Rev: 881959 $ $Date: 2009-11-18 22:07:09 +0000 (Wed, 18 Nov 2009) $ - */ -public class TestBindingWSAxisHandler extends AbstractHandler -{ - private String name; - - public TestBindingWSAxisHandler(String name) - { - this.name = name; - } - - public InvocationResponse invoke(MessageContext msgContext) throws AxisFault { - StatusImpl.appendStatus("TestAxisHandler.invoke()", name); - return InvocationResponse.CONTINUE; - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicy.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicy.java deleted file mode 100644 index c7803f03bc..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicy.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Base; - -/** - * Implementation for policies that could be injected as parameter - * into the axis2config. - * - * @version $Rev: 824551 $ $Date: 2009-10-13 01:21:22 +0100 (Tue, 13 Oct 2009) $ - */ -public class TestBindingWSPolicy { - static final String SCA11_NS = Base.SCA11_NS; - static final String SCA11_TUSCANY_NS = Base.SCA11_TUSCANY_NS; - static final QName TEST_BINDINGWS_POLICY_QNAME = new QName(SCA11_TUSCANY_NS, "testBindingWSPolicy"); - - private String testString; - - public String getTestString() { - return testString; - } - - public void setTestString(String testString) { - this.testString = testString; - } - - public QName getSchemaName() { - return TEST_BINDINGWS_POLICY_QNAME; - } - - public boolean isUnresolved() { - return false; - } - - public void setUnresolved(boolean unresolved) { - } - - @Override - public String toString() { - return "TestBindingWSPolicy [testString=" + - testString - + "]"; - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyBuilder.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyBuilder.java deleted file mode 100644 index 4fdcde678d..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyBuilder.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import java.util.ArrayList; -import java.util.List; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.assembly.Implementation; -import org.apache.tuscany.sca.assembly.builder.BuilderContext; -import org.apache.tuscany.sca.assembly.builder.PolicyBuilder; -import org.apache.tuscany.sca.policy.PolicyExpression; -import org.apache.tuscany.sca.policy.PolicySet; -import org.apache.tuscany.sca.policy.PolicySubject; - -/** - * - */ -public class TestBindingWSPolicyBuilder implements PolicyBuilder { - - public boolean build(Endpoint endpoint, BuilderContext context) { - List polices = getPolicies(endpoint); - System.out.println(endpoint + ": " + polices); - return true; - } - - public boolean build(EndpointReference endpointReference, BuilderContext context) { - List polices = getPolicies(endpointReference); - System.out.println(endpointReference + ": " + polices); - return true; - } - - public boolean build(Component component, Implementation implementation, BuilderContext context) { - List polices = getPolicies(implementation); - System.out.println(implementation + ": " + polices); - return true; - } - - public QName getPolicyType() { - return TestBindingWSPolicy.TEST_BINDINGWS_POLICY_QNAME; - } - - public List getSupportedBindings() { - return null; - } - - private List getPolicies(PolicySubject subject) { - List polices = new ArrayList(); - for (PolicySet ps : subject.getPolicySets()) { - for (PolicyExpression exp : ps.getPolicies()) { - if (getPolicyType().equals(exp.getName())) { - polices.add((TestBindingWSPolicy)exp.getPolicy()); - } - } - } - return polices; - } - - public boolean build(EndpointReference endpointReference, Endpoint endpoint, BuilderContext context) { - return true; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyInterceptor.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyInterceptor.java deleted file mode 100644 index aa33c74aea..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyInterceptor.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import helloworld.StatusImpl; - -import java.util.List; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.core.invocation.InterceptorAsyncImpl; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Message; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.policy.PolicySubject; - - -public class TestBindingWSPolicyInterceptor extends InterceptorAsyncImpl implements PhasedInterceptor { - - private Operation operation; - private List policies; - private PolicySubject subject; - private String context; - private String phase; - - public TestBindingWSPolicyInterceptor(PolicySubject subject, - String context, - Operation operation, - List policies, - String phase) { - super(); - this.operation = operation; - this.policies = policies; - this.subject = subject; - this.phase = phase; - this.context = getContext(); - } - - private String getContext() { - if (subject instanceof Endpoint) { - Endpoint endpoint = (Endpoint)subject; - return endpoint.getURI(); - } else if (subject instanceof EndpointReference) { - EndpointReference endpointReference = (EndpointReference)subject; - return endpointReference.getURI(); - } else if (subject instanceof Component) { - Component component = (Component)subject; - return component.getURI(); - } - return null; - } - - public Message processRequest(Message msg) { - StatusImpl.appendStatus("TestBindingWSPolicyInterceptor.processRequest()", context + " @ " + phase); - return msg; - } - - public Message processResponse(Message msg) { - StatusImpl.appendStatus("TestBindingWSPolicyInterceptor.processResponse()", context + " @ " + phase); - return msg; - } - - public String getPhase() { - return phase; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProcessor.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProcessor.java deleted file mode 100644 index 2b013f7ba2..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProcessor.java +++ /dev/null @@ -1,99 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; -import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; - -import java.util.logging.Level; - -import javax.xml.namespace.QName; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; -import javax.xml.stream.XMLStreamWriter; - -import org.apache.tuscany.sca.contribution.processor.ContributionReadException; -import org.apache.tuscany.sca.contribution.processor.ContributionResolveException; -import org.apache.tuscany.sca.contribution.processor.ContributionWriteException; -import org.apache.tuscany.sca.contribution.processor.ProcessorContext; -import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; -import org.apache.tuscany.sca.contribution.resolver.ModelResolver; -import org.apache.tuscany.sca.core.FactoryExtensionPoint; - -/** - * - * @version $Rev: 883438 $ $Date: 2009-11-23 18:07:34 +0000 (Mon, 23 Nov 2009) $ - */ -public class TestBindingWSPolicyProcessor implements StAXArtifactProcessor { - - public QName getArtifactType() { - return TestBindingWSPolicy.TEST_BINDINGWS_POLICY_QNAME; - } - - public TestBindingWSPolicyProcessor(FactoryExtensionPoint modelFactories) { - } - - - public TestBindingWSPolicy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException { - TestBindingWSPolicy policy = new TestBindingWSPolicy(); - int event = reader.getEventType(); - QName name = null; - - - while (reader.hasNext()) { - event = reader.getEventType(); - switch (event) { - case START_ELEMENT : { - name = reader.getName(); - if ( name.equals("testString") ) { - String testString = reader.getAttributeValue(null, "testString"); - policy.setTestString(testString); - } - break; - } - } - - if ( event == END_ELEMENT ) { - if ( TestBindingWSPolicy.TEST_BINDINGWS_POLICY_QNAME.equals(reader.getName()) ) { - break; - } - } - - //Read the next element - if (reader.hasNext()) { - reader.next(); - } - } - - return policy; - } - - public void write(TestBindingWSPolicy policy, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, XMLStreamException { - // TODO - } - - public Class getModelType() { - return TestBindingWSPolicy.class; - } - - public void resolve(TestBindingWSPolicy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException { - - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderFactory.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderFactory.java deleted file mode 100644 index df626a10ff..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderFactory.java +++ /dev/null @@ -1,69 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.provider.PolicyProvider; -import org.apache.tuscany.sca.provider.PolicyProviderFactory; -import org.apache.tuscany.sca.runtime.RuntimeComponent; - -/** - * @version $Rev: 792622 $ $Date: 2009-07-09 19:14:18 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestBindingWSPolicyProviderFactory implements PolicyProviderFactory { - private ExtensionPointRegistry registry; - - public TestBindingWSPolicyProviderFactory(ExtensionPointRegistry registry) { - super(); - this.registry = registry; - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProviderFactory#createImplementationPolicyProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, org.apache.tuscany.sca.assembly.Implementation) - */ - public PolicyProvider createImplementationPolicyProvider(RuntimeComponent component) { - // no implementation provider for this binding specific policy - return null; - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProviderFactory#createReferencePolicyProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, org.apache.tuscany.sca.runtime.RuntimeComponentReference, org.apache.tuscany.sca.assembly.Binding) - */ - public PolicyProvider createReferencePolicyProvider(EndpointReference endpointReference) { - return new TestBindingWSPolicyProviderReference(endpointReference); - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProviderFactory#createServicePolicyProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, org.apache.tuscany.sca.runtime.RuntimeComponentService, org.apache.tuscany.sca.assembly.Binding) - */ - public PolicyProvider createServicePolicyProvider(Endpoint endpoint) { - return new TestBindingWSPolicyProviderService(endpoint); - } - - /** - * @see org.apache.tuscany.sca.provider.ProviderFactory#getModelType() - */ - public Class getModelType() { - return TestBindingWSPolicy.class; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderReference.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderReference.java deleted file mode 100644 index 489c069ea8..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderReference.java +++ /dev/null @@ -1,72 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import helloworld.StatusImpl; - -import java.util.List; - -import org.apache.axis2.context.ConfigurationContext; -import org.apache.axis2.engine.AxisConfiguration; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.binding.ws.axis2.provider.Axis2BaseBindingProvider; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; - -/** - * @version $Rev: 792641 $ $Date: 2009-07-09 20:13:08 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestBindingWSPolicyProviderReference extends BasePolicyProvider { - - public TestBindingWSPolicyProviderReference(EndpointReference endpointReference) { - super(TestBindingWSPolicy.class, endpointReference); - } - - public void configureBinding(Object configuration) { - super.configureBinding(configuration); - - StatusImpl.appendStatus("TestBindingWSPolicyProviderReference.configureBinding()", configuration.getClass().getName()); - - Axis2BaseBindingProvider bindingProvider = (Axis2BaseBindingProvider)configuration; - ConfigurationContext axisConfigurationContext = bindingProvider.getAxisConfigurationContext(); - AxisConfiguration axisConfiguration = axisConfigurationContext.getAxisConfiguration(); - List outPhases = axisConfiguration.getOutFlowPhases(); - outPhases.get(0).addHandler(new TestBindingWSAxisHandler("Reference OutFlow Handler")); - List inPhases = axisConfiguration.getInFlowPhases(); - inPhases.get(0).addHandler(new TestBindingWSAxisHandler("Reference InFlow Handler")); - List inFaultPhases = axisConfiguration.getInFaultFlowPhases(); - inFaultPhases.get(0).addHandler(new TestBindingWSAxisHandler("Reference InFaultFlow Handler")); - } - - public PhasedInterceptor createBindingInterceptor() { - List policies = findPolicies(); - - if (policies.isEmpty()){ - return null; - } else { - return new TestBindingWSPolicyInterceptor(subject, - getContext(), - null, - policies, - Phase.REFERENCE_BINDING_POLICY); - } - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderService.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderService.java deleted file mode 100644 index 9880bf04b0..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testbindingwspolicy/TestBindingWSPolicyProviderService.java +++ /dev/null @@ -1,72 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testbindingwspolicy; - -import helloworld.StatusImpl; - -import java.util.List; - -import org.apache.axis2.context.ConfigurationContext; -import org.apache.axis2.engine.AxisConfiguration; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.binding.ws.axis2.provider.Axis2BaseBindingProvider; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; - -/** - * @version $Rev: 792641 $ $Date: 2009-07-09 20:13:08 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestBindingWSPolicyProviderService extends BasePolicyProvider { - - public TestBindingWSPolicyProviderService(Endpoint endpoint) { - super(TestBindingWSPolicy.class, endpoint); - } - - public void configureBinding(Object configuration) { - super.configureBinding(configuration); - - StatusImpl.appendStatus("TestBindingWSPolicyProviderService.configureBinding()", configuration.getClass().getName()); - - Axis2BaseBindingProvider bindingProvider = (Axis2BaseBindingProvider)configuration; - ConfigurationContext axisConfigurationContext = bindingProvider.getAxisConfigurationContext(); - AxisConfiguration axisConfiguration = axisConfigurationContext.getAxisConfiguration(); - List inPhases = axisConfiguration.getInFlowPhases(); - inPhases.get(0).addHandler(new TestBindingWSAxisHandler("Service InFlow Handler")); - List outPhases = axisConfiguration.getOutFlowPhases(); - outPhases.get(0).addHandler(new TestBindingWSAxisHandler("Service OutFlow Handler")); - List outFaultPhases = axisConfiguration.getOutFaultFlowPhases(); - outFaultPhases.get(0).addHandler(new TestBindingWSAxisHandler("Service OutFaultFlow Handler")); - } - - public PhasedInterceptor createBindingInterceptor() { - List policies = findPolicies(); - - if (policies.isEmpty()){ - return null; - } else { - return new TestBindingWSPolicyInterceptor(subject, - getContext(), - null, - policies, - Phase.SERVICE_BINDING_POLICY); - } - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicy.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicy.java deleted file mode 100644 index 651208fa76..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicy.java +++ /dev/null @@ -1,63 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Base; - -/** - * Implementation for policies that could be injected as parameter - * into the axis2config. - * - * @version $Rev: 824551 $ $Date: 2009-10-13 01:21:22 +0100 (Tue, 13 Oct 2009) $ - */ -public class TestPolicy { - static final String SCA11_NS = Base.SCA11_NS; - static final String SCA11_TUSCANY_NS = Base.SCA11_TUSCANY_NS; - static final QName TEST_POLICY_QNAME = new QName(SCA11_TUSCANY_NS, "testPolicy"); - - private String testString; - - public String getTestString() { - return testString; - } - - public void setTestString(String testString) { - this.testString = testString; - } - - public QName getSchemaName() { - return TEST_POLICY_QNAME; - } - - public boolean isUnresolved() { - return false; - } - - public void setUnresolved(boolean unresolved) { - } - - @Override - public String toString() { - return "TestPolicy [testString=" + - testString - + "]"; - } -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyBuilder.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyBuilder.java deleted file mode 100644 index a7cceec4de..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyBuilder.java +++ /dev/null @@ -1,84 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import java.util.ArrayList; -import java.util.List; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.assembly.Implementation; -import org.apache.tuscany.sca.assembly.builder.BuilderContext; -import org.apache.tuscany.sca.assembly.builder.PolicyBuilder; -import org.apache.tuscany.sca.policy.PolicyExpression; -import org.apache.tuscany.sca.policy.PolicySet; -import org.apache.tuscany.sca.policy.PolicySubject; - -/** - * - */ -public class TestPolicyBuilder implements PolicyBuilder { - - public boolean build(Endpoint endpoint, BuilderContext context) { - List polices = getPolicies(endpoint); - System.out.println(endpoint + ": " + polices); - return true; - } - - public boolean build(EndpointReference endpointReference, BuilderContext context) { - List polices = getPolicies(endpointReference); - System.out.println(endpointReference + ": " + polices); - return true; - } - - public boolean build(Component component, Implementation implementation, BuilderContext context) { - List polices = getPolicies(implementation); - System.out.println(implementation + ": " + polices); - return true; - } - - public QName getPolicyType() { - return TestPolicy.TEST_POLICY_QNAME; - } - - public List getSupportedBindings() { - return null; - } - - private List getPolicies(PolicySubject subject) { - List polices = new ArrayList(); - for (PolicySet ps : subject.getPolicySets()) { - for (PolicyExpression exp : ps.getPolicies()) { - if (getPolicyType().equals(exp.getName())) { - polices.add((TestPolicy)exp.getPolicy()); - } - } - } - return polices; - } - - public boolean build(EndpointReference endpointReference, Endpoint endpoint, BuilderContext context) { - return true; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyInterceptor.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyInterceptor.java deleted file mode 100644 index f03247c4d5..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyInterceptor.java +++ /dev/null @@ -1,110 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import helloworld.StatusImpl; - -import java.util.List; -import java.util.logging.ConsoleHandler; -import java.util.logging.Handler; -import java.util.logging.Level; -import java.util.logging.Logger; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.core.invocation.InterceptorAsyncImpl; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Invoker; -import org.apache.tuscany.sca.invocation.Message; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.policy.PolicySubject; - - -public class TestPolicyInterceptor extends InterceptorAsyncImpl implements PhasedInterceptor { - - private Operation operation; - private List policies; - private PolicySubject subject; - private String context; - private String phase; - - public TestPolicyInterceptor(PolicySubject subject, - String context, - Operation operation, - List policies, - String phase) { - super(); - this.operation = operation; - this.policies = policies; - this.subject = subject; - this.phase = phase; - this.context = getContext(); - } - - private String getContext() { - if (subject instanceof Endpoint) { - Endpoint endpoint = (Endpoint)subject; - return endpoint.getURI(); - } else if (subject instanceof EndpointReference) { - EndpointReference endpointReference = (EndpointReference)subject; - return endpointReference.getURI(); - } else if (subject instanceof Component) { - Component component = (Component)subject; - return component.getURI(); - } - return null; - } - - public Message processRequest(Message msg) { - String policyStrings = ""; - for (TestPolicy testPolicy : policies){ - policyStrings += testPolicy.getTestString() + " "; - } - StatusImpl.appendStatus("TestPolicyInterceptor.processRequest()", context + " @ " + phase + " testPolicyStringes " + policyStrings); - return msg; - } - - public Message postProcessRequest(Message msg, Throwable e) throws Throwable { - StatusImpl.appendStatus("TestPolicyInterceptor.postProcessRequest()", context + " @ " + phase); - return msg; - } - - public Message processResponse(Message msg) { - String policyStrings = ""; - for (TestPolicy testPolicy : policies){ - policyStrings += testPolicy.getTestString() + " "; - } - StatusImpl.appendStatus("TestPolicyInterceptor.processResponse()", context + " @ " + phase + " testPolicyStringes " + policyStrings); - return msg; - } -/* not in interface - should we add it? - public Message postProcessResponse(Message msg) { - System.out.println("TestPolicyInterceptor.postProcessResponse() " + context + " @ " + phase); - return msg; - } -*/ - - public String getPhase() { - return phase; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProcessor.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProcessor.java deleted file mode 100644 index df31399959..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProcessor.java +++ /dev/null @@ -1,99 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; -import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; - -import java.util.logging.Level; - -import javax.xml.namespace.QName; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; -import javax.xml.stream.XMLStreamWriter; - -import org.apache.tuscany.sca.contribution.processor.ContributionReadException; -import org.apache.tuscany.sca.contribution.processor.ContributionResolveException; -import org.apache.tuscany.sca.contribution.processor.ContributionWriteException; -import org.apache.tuscany.sca.contribution.processor.ProcessorContext; -import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; -import org.apache.tuscany.sca.contribution.resolver.ModelResolver; -import org.apache.tuscany.sca.core.FactoryExtensionPoint; - -/** - * - * @version $Rev: 883438 $ $Date: 2009-11-23 18:07:34 +0000 (Mon, 23 Nov 2009) $ - */ -public class TestPolicyProcessor implements StAXArtifactProcessor { - - public QName getArtifactType() { - return TestPolicy.TEST_POLICY_QNAME; - } - - public TestPolicyProcessor(FactoryExtensionPoint modelFactories) { - } - - - public TestPolicy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException { - TestPolicy policy = new TestPolicy(); - int event = reader.getEventType(); - QName name = null; - - - while (reader.hasNext()) { - event = reader.getEventType(); - switch (event) { - case START_ELEMENT : { - name = reader.getName(); - if ( name.getLocalPart().equals("testPolicy") ) { - String testString = reader.getAttributeValue(null, "testString"); - policy.setTestString(testString); - } - break; - } - } - - if ( event == END_ELEMENT ) { - if ( TestPolicy.TEST_POLICY_QNAME.equals(reader.getName()) ) { - break; - } - } - - //Read the next element - if (reader.hasNext()) { - reader.next(); - } - } - - return policy; - } - - public void write(TestPolicy policy, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, XMLStreamException { - // TODO - } - - public Class getModelType() { - return TestPolicy.class; - } - - public void resolve(TestPolicy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException { - - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderFactory.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderFactory.java deleted file mode 100644 index 75cb298f2d..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderFactory.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.provider.PolicyProvider; -import org.apache.tuscany.sca.provider.PolicyProviderFactory; -import org.apache.tuscany.sca.runtime.RuntimeComponent; - -/** - * @version $Rev: 792622 $ $Date: 2009-07-09 19:14:18 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestPolicyProviderFactory implements PolicyProviderFactory { - private ExtensionPointRegistry registry; - - public TestPolicyProviderFactory(ExtensionPointRegistry registry) { - super(); - this.registry = registry; - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProviderFactory#createImplementationPolicyProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, org.apache.tuscany.sca.assembly.Implementation) - */ - public PolicyProvider createImplementationPolicyProvider(RuntimeComponent component) { - return new TestPolicyProviderImplementation(component); - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProviderFactory#createReferencePolicyProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, org.apache.tuscany.sca.runtime.RuntimeComponentReference, org.apache.tuscany.sca.assembly.Binding) - */ - public PolicyProvider createReferencePolicyProvider(EndpointReference endpointReference) { - return new TestPolicyProviderReference(endpointReference); - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProviderFactory#createServicePolicyProvider(org.apache.tuscany.sca.runtime.RuntimeComponent, org.apache.tuscany.sca.runtime.RuntimeComponentService, org.apache.tuscany.sca.assembly.Binding) - */ - public PolicyProvider createServicePolicyProvider(Endpoint endpoint) { - return new TestPolicyProviderService(endpoint); - } - - /** - * @see org.apache.tuscany.sca.provider.ProviderFactory#getModelType() - */ - public Class getModelType() { - return TestPolicy.class; - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderImplementation.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderImplementation.java deleted file mode 100644 index b027763d22..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderImplementation.java +++ /dev/null @@ -1,56 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import java.util.List; - -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; -import org.apache.tuscany.sca.runtime.RuntimeComponent; - -/** - * @version $Rev: 792641 $ $Date: 2009-07-09 20:13:08 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestPolicyProviderImplementation extends BasePolicyProvider { - - public TestPolicyProviderImplementation(RuntimeComponent component) { - super(TestPolicy.class, component.getImplementation()); - } - - /** - * @see org.apache.tuscany.sca.provider.PolicyProvider#createInterceptor(org.apache.tuscany.sca.interfacedef.Operation) - */ - public PhasedInterceptor createInterceptor(Operation operation) { - List policies = findPolicies(); - - if (policies.isEmpty()){ - return null; - } else { - return new TestPolicyInterceptor(subject, - getContext(), - operation, - policies, - Phase.IMPLEMENTATION_POLICY); - } - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderReference.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderReference.java deleted file mode 100644 index 3e784aa62e..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderReference.java +++ /dev/null @@ -1,53 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import java.util.List; - -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; - -/** - * @version $Rev: 792641 $ $Date: 2009-07-09 20:13:08 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestPolicyProviderReference extends BasePolicyProvider { - - public TestPolicyProviderReference(EndpointReference endpointReference) { - super(TestPolicy.class, endpointReference); - } - - public PhasedInterceptor createInterceptor(Operation operation) { - List policies = findPolicies(); - - if (policies.isEmpty()){ - return null; - } else { - return new TestPolicyInterceptor(subject, - getContext(), - operation, - policies, - Phase.REFERENCE_POLICY); - } - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderService.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderService.java deleted file mode 100644 index 5066193aa6..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/java/testpolicy/TestPolicyProviderService.java +++ /dev/null @@ -1,53 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 testpolicy; - -import java.util.List; - -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; - -/** - * @version $Rev: 792641 $ $Date: 2009-07-09 20:13:08 +0100 (Thu, 09 Jul 2009) $ - */ -public class TestPolicyProviderService extends BasePolicyProvider { - - public TestPolicyProviderService(Endpoint endpoint) { - super(TestPolicy.class, endpoint); - } - - public PhasedInterceptor createInterceptor(Operation operation) { - List policies = findPolicies(); - - if (policies.isEmpty()){ - return null; - } else { - return new TestPolicyInterceptor(subject, - getContext(), - operation, - policies, - Phase.SERVICE_POLICY); - } - } - -} diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/sca-contribution.xml b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/sca-contribution.xml deleted file mode 100644 index 350ad6be96..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/sca-contribution.xml +++ /dev/null @@ -1,23 +0,0 @@ - - - - - \ No newline at end of file diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder deleted file mode 100644 index d2138222a6..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder +++ /dev/null @@ -1,18 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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. -testpolicy.TestPolicyBuilder;qname=http://tuscany.apache.org/xmlns/sca/1.1#testPolicy -testbindingwspolicy.TestBindingWSPolicyBuilder;qname=http://tuscany.apache.org/xmlns/sca/1.1#testBindingWSPolicy diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor deleted file mode 100644 index afe19cdffc..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor +++ /dev/null @@ -1,21 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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. - -# Implementation class for the artifact processor extension -testpolicy.TestPolicyProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.1#testPolicy,model=testpolicy.TestPolicy -testbindingwspolicy.TestBindingWSPolicyProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.1#testBindingWSPolicy,model=testbindingwspolicy.TestBindingWSPolicy - diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions deleted file mode 100644 index f362b64a1f..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions +++ /dev/null @@ -1,17 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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. -definitions.xml diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory deleted file mode 100644 index f5c82538be..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory +++ /dev/null @@ -1,21 +0,0 @@ -# Licensed to the Apache Software Foundation (ASF) under one -# or more contributor license agreements. See the NOTICE file -# distributed with this work for additional information -# regarding copyright ownership. The ASF licenses this file -# to you 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. - -# Implementation class for the policy extension -testpolicy.TestPolicyProviderFactory;model=testpolicy.TestPolicy -testbindingwspolicy.TestBindingWSPolicyProviderFactory;model=testbindingwspolicy.TestBindingWSPolicy - diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/definitions.xml b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/definitions.xml deleted file mode 100644 index 39d3d25a78..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/definitions.xml +++ /dev/null @@ -1,48 +0,0 @@ - - - - - - - - - - - - - - - - - - \ No newline at end of file diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.composite b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.composite deleted file mode 100644 index 28fef03db5..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.composite +++ /dev/null @@ -1,40 +0,0 @@ - - - - - - - - - - - - - - - - - diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.wsdl b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.wsdl deleted file mode 100644 index 15b89dbcea..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/main/resources/helloworld.wsdl +++ /dev/null @@ -1,90 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - diff --git a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/test/java/interceptors/HelloworldTestCase.java b/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/test/java/interceptors/HelloworldTestCase.java deleted file mode 100644 index 933c8e42cc..0000000000 --- a/sca-java-2.x/tags/2.0.1-RC1/testing/itest/policy/reliability/src/test/java/interceptors/HelloworldTestCase.java +++ /dev/null @@ -1,87 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 interceptors; - -import java.util.List; - -import junit.framework.Assert; -import junit.framework.TestCase; - -import helloworld.HelloWorld; -import helloworld.HelloWorldException; -import helloworld.StatusImpl; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Composite; -import org.apache.tuscany.sca.node.Contribution; -import org.apache.tuscany.sca.node.Node; -import org.apache.tuscany.sca.node.NodeFactory; -import org.apache.tuscany.sca.node.impl.NodeImpl; -import org.apache.tuscany.sca.policy.Intent; -import org.apache.tuscany.sca.policy.PolicySet; -import org.junit.Ignore; - -public class HelloworldTestCase extends TestCase { - - private Node node; - private HelloWorld helloWorld; - - @Override - protected void setUp() throws Exception { - StatusImpl.statusString = ""; - - node = NodeFactory.newInstance().createNode("helloworld.composite", new Contribution("test", "target/classes")); - node.start(); - helloWorld = node.getService(HelloWorld.class, "HelloWorldClient/HelloWorld"); - } - - /* - * We're not testing real reliability policy here. Just checking that the - * exactlyOnce profile intent is handled correctly and presented as its - * constituent atMostOnce and atLeastOnce intents. - */ - public void testReliabilityIntent() throws Exception { - // check response from application - assertEquals("Hello fred", helloWorld.getGreetings("fred")); - - // check sequences of interceptors - System.out.println(StatusImpl.statusString); - assertTrue(StatusImpl.statusString.contains("atmostonce")); - assertTrue(StatusImpl.statusString.contains("exactlyonce")); - assertTrue(StatusImpl.statusString.contains("atleastonce")); - - - // check final intents on endpoint reference to see if the matching process - // results on the right set - Composite domainComposite = ((NodeImpl)node).getDomainComposite(); - List intents = domainComposite.getComponents().get(0).getReferences().get(0).getEndpointReferences().get(0).getRequiredIntents(); - - assertEquals(2, intents.size()); - assertEquals("atMostOnce", intents.get(0).getName().getLocalPart()); - assertEquals("atLeastOnce", intents.get(1).getName().getLocalPart()); - - } - - @Override - protected void tearDown() throws Exception { - node.stop(); - } - -} -- cgit v1.2.3