Repository: syncope Updated Branches: refs/heads/master 012f97bca -> 6ae502003
http://git-wip-us.apache.org/repos/asf/syncope/blob/6ae50200/ext/camel/provisioning-camel/src/main/resources/META-INF/services/org/apache/camel/component/propagate ---------------------------------------------------------------------- diff --git a/ext/camel/provisioning-camel/src/main/resources/META-INF/services/org/apache/camel/component/propagate b/ext/camel/provisioning-camel/src/main/resources/META-INF/services/org/apache/camel/component/propagate new file mode 100644 index 0000000..92513e8 --- /dev/null +++ b/ext/camel/provisioning-camel/src/main/resources/META-INF/services/org/apache/camel/component/propagate @@ -0,0 +1,19 @@ +# +# 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. +# +class=org.apache.syncope.core.provisioning.camel.component.PropagateComponent \ No newline at end of file http://git-wip-us.apache.org/repos/asf/syncope/blob/6ae50200/ext/camel/provisioning-camel/src/main/resources/anyObjectRoutes.xml ---------------------------------------------------------------------- diff --git a/ext/camel/provisioning-camel/src/main/resources/anyObjectRoutes.xml b/ext/camel/provisioning-camel/src/main/resources/anyObjectRoutes.xml index 5c23f9e..15c457c 100644 --- a/ext/camel/provisioning-camel/src/main/resources/anyObjectRoutes.xml +++ b/ext/camel/provisioning-camel/src/main/resources/anyObjectRoutes.xml @@ -26,7 +26,7 @@ under the License. </setProperty> <doTry> <bean ref="awfAdapter" method="create(${body})"/> - <process ref="createProcessor"/> + <to uri="propagate:create?anyType=any"/> <to uri="direct:createAnyObjectPort"/> <doCatch> <exception>java.lang.RuntimeException</exception> @@ -45,7 +45,7 @@ under the License. </setProperty> <doTry> <bean ref="awfAdapter" method="update(${body})"/> - <process ref="updateProcessor"/> + <to uri="propagate:update?anyType=any"/> <to uri="direct:updateAnyObjectPort"/> <doCatch> <exception>java.lang.RuntimeException</exception> @@ -60,7 +60,7 @@ under the License. <route id="deleteAnyObject"> <from uri="direct:deleteAnyObject"/> <doTry> - <process ref="anyObjectDeleteProcessor"/> + <to uri="propagate:delete?anyType=any"/> <bean ref="awfAdapter" method="delete(${body})"/> <setBody> <simple>${property.statuses}</simple> @@ -114,13 +114,13 @@ under the License. <route id="provisionAnyObject"> <from uri="direct:provisionAnyObject"/> - <process ref="anyObjectProvisionProcessor"/> + <to uri="propagate:provision?anyType=any"/> <to uri="direct:provisionAnyObjectPort"/> </route> <route id="deprovisionAnyObject"> <from uri="direct:deprovisionAnyObject"/> - <process ref="anyObjectDeprovisionProcessor"/> + <to uri="propagate:deprovision?anyType=any"/> <to uri="direct:deprovisionAnyObjectPort"/> </route> http://git-wip-us.apache.org/repos/asf/syncope/blob/6ae50200/ext/camel/provisioning-camel/src/main/resources/groupRoutes.xml ---------------------------------------------------------------------- diff --git a/ext/camel/provisioning-camel/src/main/resources/groupRoutes.xml b/ext/camel/provisioning-camel/src/main/resources/groupRoutes.xml index c76fa61..d21c220 100644 --- a/ext/camel/provisioning-camel/src/main/resources/groupRoutes.xml +++ b/ext/camel/provisioning-camel/src/main/resources/groupRoutes.xml @@ -26,7 +26,7 @@ under the License. </setProperty> <doTry> <bean ref="gwfAdapter" method="create(${body})"/> - <process ref="createProcessor"/> + <to uri="propagate:create?anyType=group"/> <to uri="direct:createGroupPort"/> <doCatch> <exception>java.lang.RuntimeException</exception> @@ -64,7 +64,7 @@ under the License. </setProperty> <doTry> <bean ref="gwfAdapter" method="update(${body})"/> - <process ref="updateProcessor"/> + <to uri="propagate:update?anyType=group"/> <to uri="direct:updateGroupPort"/> <doCatch> <exception>java.lang.RuntimeException</exception> @@ -79,7 +79,7 @@ under the License. <route id="deleteGroup"> <from uri="direct:deleteGroup"/> <doTry> - <process ref="groupDeleteProcessor"/> + <to uri="propagate:delete?anyType=group"/> <bean ref="gwfAdapter" method="delete(${body})"/> <setBody> <simple>${property.statuses}</simple> @@ -133,13 +133,13 @@ under the License. <route id="provisionGroup"> <from uri="direct:provisionGroup"/> - <process ref="groupProvisionProcessor"/> + <to uri="propagate:provision?anyType=group"/> <to uri="direct:provisionGroupPort"/> </route> <route id="deprovisionGroup"> <from uri="direct:deprovisionGroup"/> - <process ref="groupDeprovisionProcessor"/> + <to uri="propagate:deprovision?anyType=group"/> <to uri="direct:deprovisionGroupPort"/> </route> http://git-wip-us.apache.org/repos/asf/syncope/blob/6ae50200/ext/camel/provisioning-camel/src/main/resources/userRoutes.xml ---------------------------------------------------------------------- diff --git a/ext/camel/provisioning-camel/src/main/resources/userRoutes.xml b/ext/camel/provisioning-camel/src/main/resources/userRoutes.xml index aa86463..73564f9 100644 --- a/ext/camel/provisioning-camel/src/main/resources/userRoutes.xml +++ b/ext/camel/provisioning-camel/src/main/resources/userRoutes.xml @@ -27,7 +27,7 @@ under the License. <doTry> <bean method="create(${body},${property.disablePwdPolicyCheck},${property.enabled},${property.storePassword})" ref="uwfAdapter" /> - <process ref="createProcessor"/> + <to uri="propagate:create?anyType=user"/> <to uri="direct:createPort"/> <doCatch> <exception>java.lang.RuntimeException</exception> @@ -46,7 +46,7 @@ under the License. </setProperty> <doTry> <bean ref="uwfAdapter" method="update(${body})"/> - <process ref="updateProcessor"/> + <to uri="propagate:update?anyType=user"/> <to uri="direct:updatePort"/> <doCatch> <exception>java.lang.RuntimeException</exception> @@ -83,7 +83,7 @@ under the License. <route id="deleteUser"> <from uri="direct:deleteUser"/> <doTry> - <process ref="userDeleteProcessor"/> + <to uri="propagate:delete?anyType=user"/> <bean ref="uwfAdapter" method="delete(${body})"/> <setBody> <simple>${property.statuses}</simple> @@ -188,13 +188,13 @@ under the License. <route id="provisionUser"> <from uri="direct:provisionUser"/> - <process ref="userProvisionProcessor"/> + <to uri="propagate:provision?anyType=user"/> <to uri="direct:provisionPort"/> </route> <route id="deprovisionUser"> <from uri="direct:deprovisionUser"/> - <process ref="userDeprovisionProcessor"/> + <to uri="propagate:deprovision?anyType=user"/> <to uri="direct:deprovisionPort"/> </route> http://git-wip-us.apache.org/repos/asf/syncope/blob/6ae50200/fit/core-reference/src/test/java/org/apache/syncope/fit/core/CamelRouteITCase.java ---------------------------------------------------------------------- diff --git a/fit/core-reference/src/test/java/org/apache/syncope/fit/core/CamelRouteITCase.java b/fit/core-reference/src/test/java/org/apache/syncope/fit/core/CamelRouteITCase.java index ce2c638..d545d2f 100644 --- a/fit/core-reference/src/test/java/org/apache/syncope/fit/core/CamelRouteITCase.java +++ b/fit/core-reference/src/test/java/org/apache/syncope/fit/core/CamelRouteITCase.java @@ -87,7 +87,7 @@ public class CamelRouteITCase extends AbstractITCase { + " <doTry>\n" + " <bean ref=\"uwfAdapter\" method=\"create(${body},${property.disablePwdPolicyCheck},\n" + " ${property.enabled},${property.storePassword})\"/>\n" - + " <process ref=\"createProcessor\" />\n" + + " <to uri=\"propagate:create?anyType=user\"/>\n" + " <to uri=\"direct:createPort\"/>\n" + " <to uri=\"log:myLog\"/>\n" + " <doCatch> \n" @@ -129,7 +129,7 @@ public class CamelRouteITCase extends AbstractITCase { + " <doTry>\n" + " <bean ref=\"uwfAdapter\" method=\"create(${body},${property.disablePwdPolicyCheck},\n" + " ${property.enabled},${property.storePassword})\"/>\n" - + " <process ref=\"createProcessor\"/>\n" + + " <to uri=\"propagate:create?anyType=user\"/>\n" + " <to uri=\"direct:createPort\"/>\n" + " <doCatch> \n" + " <exception>java.lang.RuntimeException</exception>\n"
