syncope-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ilgro...@apache.org
Subject [46/53] [abbrv] syncope git commit: Partially fixed #7
Date Mon, 05 Jan 2015 13:34:51 GMT
Partially fixed #7


Project: http://git-wip-us.apache.org/repos/asf/syncope/repo
Commit: http://git-wip-us.apache.org/repos/asf/syncope/commit/ec34515d
Tree: http://git-wip-us.apache.org/repos/asf/syncope/tree/ec34515d
Diff: http://git-wip-us.apache.org/repos/asf/syncope/diff/ec34515d

Branch: refs/heads/master
Commit: ec34515da73044960f445aa472306dbf87ca2c8e
Parents: b1d2ac6
Author: giacomolm <giacomolm@hotmail.it>
Authored: Mon Jan 5 11:53:23 2015 +0100
Committer: giacomolm <giacomolm@hotmail.it>
Committed: Mon Jan 5 11:53:23 2015 +0100

----------------------------------------------------------------------
 .../camel/CamelRoleProvisioningManager.java     | 28 +++++---------------
 .../camel/CamelUserProvisioningManager.java     | 20 +++++++++-----
 .../provisioning/camel/SyncopeCamelContext.java |  9 +++----
 .../DefaultRoleCreatePropagation.java           |  2 ++
 .../DefaultRoleCreateSyncPropagation.java       |  1 +
 .../DefaultRoleDeprovisionPropagation.java      |  1 +
 .../DefaultRoleUpdatePropagation.java           |  2 ++
 .../DefaultUserCreatePropagation.java           |  2 ++
 .../DefaultUserDeletePropagation.java           |  1 +
 .../DefaultUserDeprovisionPropagation.java      |  1 +
 .../DefaultUserStatusPropagation.java           |  1 +
 .../DefaultUserUpdateInSyncPropagation.java     |  2 ++
 .../DefaultUserUpdatePropagation.java           |  1 +
 .../DefaultUserWFSuspendPropagation.java        |  1 +
 .../camel/processors/UserStatusOnSync.java      |  1 +
 15 files changed, 40 insertions(+), 33 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelRoleProvisioningManager.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelRoleProvisioningManager.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelRoleProvisioningManager.java
index 9b121a4..96f5227 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelRoleProvisioningManager.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelRoleProvisioningManager.java
@@ -18,10 +18,7 @@
  */
 package org.apache.syncope.core.provisioning.camel;
 
-import java.io.ByteArrayInputStream;
-import java.io.File;
 import java.io.InputStream;
-import java.net.URLDecoder;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Collections;
@@ -30,39 +27,23 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import javax.xml.bind.JAXBContext;
-import javax.xml.bind.JAXBElement;
-import javax.xml.bind.Unmarshaller;
-import javax.xml.parsers.DocumentBuilder;
-import javax.xml.parsers.DocumentBuilderFactory;
-import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.PollingConsumer;
 import org.apache.camel.ProducerTemplate;
-import org.apache.camel.impl.DefaultCamelContext;
 import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.impl.DefaultMessage;
-import org.apache.camel.model.Constants;
-import org.apache.camel.model.RouteDefinition;
 import org.apache.camel.model.RoutesDefinition;
 import org.apache.camel.spring.SpringCamelContext;
 import org.apache.syncope.common.mod.RoleMod;
 import org.apache.syncope.common.to.PropagationStatus;
 import org.apache.syncope.common.to.RoleTO;
-import org.apache.syncope.core.persistence.beans.CamelRoute;
 import org.apache.syncope.core.persistence.dao.RouteDAO;
 import org.apache.syncope.core.propagation.PropagationException;
 import org.apache.syncope.core.provisioning.RoleProvisioningManager;
-import org.apache.syncope.core.util.ApplicationContextProvider;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.ApplicationContext;
-import org.w3c.dom.Document;
-import org.w3c.dom.Element;
-import org.w3c.dom.Node;
-import org.w3c.dom.NodeList;
 
 public class CamelRoleProvisioningManager implements RoleProvisioningManager {
 
@@ -84,7 +65,7 @@ public class CamelRoleProvisioningManager implements RoleProvisioningManager
{
 
     public CamelRoleProvisioningManager() throws Exception {
         knownUri = new ArrayList<String>();
-        consumerMap = new HashMap();
+        consumerMap = new HashMap<String, PollingConsumer>();
     }
 
     public void startContext() throws Exception {
@@ -165,6 +146,7 @@ public class CamelRoleProvisioningManager implements RoleProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> create(RoleTO roleTO, Set<String>
excludedResources) {
 
         String uri = "direct:createRolePort";
@@ -185,6 +167,7 @@ public class CamelRoleProvisioningManager implements RoleProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> createInSync(RoleTO roleTO,
Map<Long, String> roleOwnerMap,
             Set<String> excludedResources) throws PropagationException {
 
@@ -213,6 +196,7 @@ public class CamelRoleProvisioningManager implements RoleProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> update(RoleMod subjectMod,
Set<String> excludedResources) {
 
         String uri = "direct:updateRolePort";
@@ -233,6 +217,7 @@ public class CamelRoleProvisioningManager implements RoleProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public List<PropagationStatus> delete(Long subjectId) {
 
         String uri = "direct:deleteRolePort";
@@ -284,13 +269,14 @@ public class CamelRoleProvisioningManager implements RoleProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public List<PropagationStatus> deprovision(final Long roleId, Collection<String>
resources) {
 
         String uri = "direct:deprovisionRolePort";
 
         PollingConsumer pollingConsumer = getConsumer(uri);
 
-        Map props = new HashMap<String, Object>();
+        Map<String, Object> props = new HashMap<String, Object>();
         props.put("resources", resources);
 
         sendMessage("direct:deprovisionRole", roleId, props);

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelUserProvisioningManager.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelUserProvisioningManager.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelUserProvisioningManager.java
index 01b057a..c65f8eb 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelUserProvisioningManager.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/CamelUserProvisioningManager.java
@@ -31,12 +31,10 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
 import org.apache.camel.Exchange;
 import org.apache.camel.PollingConsumer;
 import org.apache.camel.ProducerTemplate;
-import org.apache.camel.impl.DefaultCamelContext;
 import org.apache.camel.impl.DefaultExchange;
 import org.apache.camel.impl.DefaultMessage;
 import org.apache.camel.model.RoutesDefinition;
@@ -76,7 +74,7 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
 
     public CamelUserProvisioningManager() throws Exception {
         knownUri = new ArrayList<String>();
-        consumerMap = new HashMap();
+        consumerMap = new HashMap<String, PollingConsumer>();
     }
 
     public String readerToString(Reader reader, int size) throws IOException {
@@ -177,6 +175,7 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> create(final UserTO userTO,
final boolean storePassword,
             boolean disablePwdPolicyCheck, Boolean enabled, Set<String> excludedResources)
{
         String uri = "direct:createPort";
@@ -211,6 +210,7 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> update(UserMod userMod, boolean
removeMemberships) {
         String uri = "direct:updatePort";
         PollingConsumer pollingConsumer = getConsumer(uri);
@@ -236,6 +236,7 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public List<PropagationStatus> delete(final Long userId, Set<String> excludedResources)
{
         String uri = "direct:deletePort";
         PollingConsumer pollingConsumer = getConsumer(uri);
@@ -272,11 +273,12 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> activate(SyncopeUser user,
StatusMod statusMod) {
         String uri = "direct:statusPort";
         PollingConsumer pollingConsumer = getConsumer(uri);
 
-        Map props = new HashMap<String, Object>();
+        Map<String, Object> props = new HashMap<String, Object>();
         props.put("token", statusMod.getToken());
         props.put("user", user);
         props.put("statusMod", statusMod);
@@ -299,11 +301,12 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> reactivate(SyncopeUser user,
StatusMod statusMod) {
         String uri = "direct:statusPort";
         PollingConsumer pollingConsumer = getConsumer(uri);
 
-        Map props = new HashMap<String, Object>();
+        Map<String, Object> props = new HashMap<String, Object>();
         props.put("user", user);
         props.put("statusMod", statusMod);
 
@@ -325,12 +328,13 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> suspend(SyncopeUser user,
StatusMod statusMod) {
 
         String uri = "direct:statusPort";
         PollingConsumer pollingConsumer = getConsumer(uri);
 
-        Map props = new HashMap<String, Object>();
+        Map<String, Object> props = new HashMap<String, Object>();
         props.put("user", user);
         props.put("statusMod", statusMod);
 
@@ -370,12 +374,13 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public List<PropagationStatus> deprovision(Long user, Collection<String>
resources) {
         String uri = "direct:deprovisionPort";
 
         PollingConsumer pollingConsumer = getConsumer(uri);
 
-        Map props = new HashMap<String, Object>();
+        Map<String, Object> props = new HashMap<String, Object>();
         props.put("resources", resources);
 
         sendMessage("direct:deprovisionUser", user, props);
@@ -390,6 +395,7 @@ public class CamelUserProvisioningManager implements UserProvisioningManager
{
     }
 
     @Override
+    @SuppressWarnings("unchecked")
     public Map.Entry<Long, List<PropagationStatus>> updateInSync(UserMod userMod,
Long id, SyncResult result,
             Boolean enabled, Set<String> excludedResources) {
 

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/SyncopeCamelContext.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/SyncopeCamelContext.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/SyncopeCamelContext.java
index 6d3e77d..2873735 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/SyncopeCamelContext.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/SyncopeCamelContext.java
@@ -33,6 +33,7 @@ import javax.xml.parsers.DocumentBuilderFactory;
 import org.apache.camel.CamelContext;
 import org.apache.camel.model.Constants;
 import org.apache.camel.model.RouteDefinition;
+import org.apache.camel.model.RoutesDefinition;
 import org.apache.camel.spring.SpringCamelContext;
 import org.apache.syncope.core.persistence.beans.CamelRoute;
 import org.apache.syncope.core.persistence.dao.RouteDAO;
@@ -80,16 +81,14 @@ public class SyncopeCamelContext {
             DocumentBuilder dBuilder = DocumentBuilderFactory.newInstance().newDocumentBuilder();
             JAXBContext jaxbContext = JAXBContext.newInstance(Constants.JAXB_CONTEXT_PACKAGES);
             Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
-            List rds = new ArrayList();
-
-            for (int s = 0; s < crl.size(); s++) {
-
+            List<RouteDefinition> rds = new ArrayList<RouteDefinition>();
+            for(int s = 0; s < crl.size(); s++){
                 InputStream is = new ByteArrayInputStream(URLDecoder.decode(crl.get(s).getRouteContent(),
"UTF-8").
                         getBytes());
                 Document doc = dBuilder.parse(is);
                 doc.getDocumentElement().normalize();
                 Node routeEl = doc.getElementsByTagName("route").item(0);
-                JAXBElement obj = unmarshaller.unmarshal(routeEl, RouteDefinition.class);
+                JAXBElement<RouteDefinition> obj = unmarshaller.unmarshal(routeEl,
RouteDefinition.class);
                 //adding route definition to list                        
                 rds.add(obj.getValue());
             }

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreatePropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreatePropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreatePropagation.java
index 2af3d37..43daf10 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreatePropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreatePropagation.java
@@ -53,8 +53,10 @@ public class DefaultRoleCreatePropagation implements Processor {
     @Override
     public void process(Exchange exchange) {
 
+        @SuppressWarnings("unchecked")
         WorkflowResult<Long> created = (WorkflowResult) exchange.getIn().getBody();
         RoleTO subject = exchange.getProperty("subject", RoleTO.class);
+        @SuppressWarnings("unchecked")
         Set<String> excludedResource = exchange.getProperty("excludedResources", Set.class);
 
         EntitlementUtil.extendAuthContext(created.getResult());

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreateSyncPropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreateSyncPropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreateSyncPropagation.java
index d796d6d..296d99e 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreateSyncPropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleCreateSyncPropagation.java
@@ -51,6 +51,7 @@ public class DefaultRoleCreateSyncPropagation implements Processor {
     private static final Logger LOG = LoggerFactory.getLogger(DefaultRoleCreateSyncPropagation.class);
 
     @Override
+    @SuppressWarnings("unchecked")
     public void process(Exchange exchange) {
 
         WorkflowResult<Long> created = (WorkflowResult) exchange.getIn().getBody();

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleDeprovisionPropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleDeprovisionPropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleDeprovisionPropagation.java
index a7c35fb..e196187 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleDeprovisionPropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleDeprovisionPropagation.java
@@ -54,6 +54,7 @@ public class DefaultRoleDeprovisionPropagation implements Processor {
     public void process(Exchange exchange) {
 
         Long roleId = exchange.getIn().getBody(Long.class);
+        @SuppressWarnings("unchecked")
         List<String> resources = exchange.getProperty("resources", List.class);
 
         final SyncopeRole role = binder.getRoleFromId(roleId);

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleUpdatePropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleUpdatePropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleUpdatePropagation.java
index 90d37dd..6722a15 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleUpdatePropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultRoleUpdatePropagation.java
@@ -55,8 +55,10 @@ public class DefaultRoleUpdatePropagation implements Processor {
 
     @Override
     public void process(Exchange exchange) {
+        @SuppressWarnings("unchecked")
         WorkflowResult<Long> updated = (WorkflowResult) exchange.getIn().getBody();
         RoleMod subjectMod = exchange.getProperty("subjectMod", RoleMod.class);
+        @SuppressWarnings("unchecked")
         Set<String> excludedResource = exchange.getProperty("excludedResources", Set.class);
 
         List<PropagationTask> tasks = propagationManager.getRoleUpdateTaskIds(updated,

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserCreatePropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserCreatePropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserCreatePropagation.java
index 82ba0ab..ed5b990 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserCreatePropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserCreatePropagation.java
@@ -54,8 +54,10 @@ public class DefaultUserCreatePropagation implements Processor {
 
         if ((exchange.getIn().getBody() instanceof WorkflowResult)) {
 
+            @SuppressWarnings("unchecked")
             WorkflowResult<Map.Entry<Long, Boolean>> created = (WorkflowResult)
exchange.getIn().getBody();
             UserTO actual = exchange.getProperty("actual", UserTO.class);
+            @SuppressWarnings("unchecked")
             Set<String> excludedResource = exchange.getProperty("excludedResources",
Set.class);
 
             List<PropagationTask> tasks = propagationManager.getUserCreateTaskIds(

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeletePropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeletePropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeletePropagation.java
index 3f80459..c3028ab 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeletePropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeletePropagation.java
@@ -50,6 +50,7 @@ public class DefaultUserDeletePropagation implements Processor {
         Long userId = (Long) exchange.getIn().getBody();
         LOG.info("UserId {} ", userId);
 
+        @SuppressWarnings("unchecked")
         Set<String> excludedResource = exchange.getProperty("excludedResources", Set.class);
 
         // Note here that we can only notify about "delete", not any other

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeprovisionPropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeprovisionPropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeprovisionPropagation.java
index a529dea..caa9d90 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeprovisionPropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserDeprovisionPropagation.java
@@ -54,6 +54,7 @@ public class DefaultUserDeprovisionPropagation implements Processor {
     public void process(Exchange exchange) {
 
         Long userId = exchange.getIn().getBody(Long.class);
+        @SuppressWarnings("unchecked")
         List<String> resources = exchange.getProperty("resources", List.class);
 
         final SyncopeUser user = binder.getUserFromId(userId);

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserStatusPropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserStatusPropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserStatusPropagation.java
index cc167d7..89e9dca 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserStatusPropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserStatusPropagation.java
@@ -54,6 +54,7 @@ public class DefaultUserStatusPropagation implements Processor {
     @Override
     public void process(Exchange exchange) {
 
+        @SuppressWarnings("unchecked")
         WorkflowResult<Long> updated = (WorkflowResult) exchange.getIn().getBody();
 
         SyncopeUser user = exchange.getProperty("user", SyncopeUser.class);

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdateInSyncPropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdateInSyncPropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdateInSyncPropagation.java
index a931a5b..1a9ecd3 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdateInSyncPropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdateInSyncPropagation.java
@@ -60,8 +60,10 @@ public class DefaultUserUpdateInSyncPropagation implements Processor {
     @Override
     public void process(Exchange exchange) {
 
+        @SuppressWarnings("unchecked")
         WorkflowResult<Map.Entry<UserMod, Boolean>> updated = (WorkflowResult)
exchange.getIn().getBody();
 
+        @SuppressWarnings("unchecked")
         Set<String> excludedResource = exchange.getProperty("excludedResources", Set.class);
 
         PropagationReporter propagationReporter = ApplicationContextProvider.getApplicationContext().

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdatePropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdatePropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdatePropagation.java
index c9b498e..c34a0bf 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdatePropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserUpdatePropagation.java
@@ -56,6 +56,7 @@ public class DefaultUserUpdatePropagation implements Processor {
     protected UserDataBinder binder;
 
     @Override
+    @SuppressWarnings("unchecked")
     public void process(Exchange exchange) {
 
         WorkflowResult<Map.Entry<UserMod, Boolean>> updated = (WorkflowResult)
exchange.getIn().getBody();

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserWFSuspendPropagation.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserWFSuspendPropagation.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserWFSuspendPropagation.java
index 88cd160..dcc8af8 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserWFSuspendPropagation.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/DefaultUserWFSuspendPropagation.java
@@ -47,6 +47,7 @@ public class DefaultUserWFSuspendPropagation implements Processor {
     @Override
     public void process(Exchange exchange) {
 
+        @SuppressWarnings("unchecked")
         WorkflowResult<Long> updated = (WorkflowResult) exchange.getIn().getBody();
         Boolean suspend = exchange.getProperty("suspend", Boolean.class);
 

http://git-wip-us.apache.org/repos/asf/syncope/blob/ec34515d/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/UserStatusOnSync.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/UserStatusOnSync.java
b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/UserStatusOnSync.java
index 7cb7dfa..182913b 100644
--- a/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/UserStatusOnSync.java
+++ b/core/src/main/java/org/apache/syncope/core/provisioning/camel/processors/UserStatusOnSync.java
@@ -45,6 +45,7 @@ public class UserStatusOnSync implements Processor {
     @Override
     public void process(Exchange exchange) {
 
+        @SuppressWarnings("unchecked")
         WorkflowResult<Map.Entry<UserMod, Boolean>> updated = (WorkflowResult)
exchange.getIn().getBody();
 
         Boolean enabled = exchange.getProperty("enabled", Boolean.class);


Mime
View raw message