You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@syncope.apache.org by il...@apache.org on 2015/01/05 14:34:51 UTC
[46/53] [abbrv] syncope git commit: Partially fixed #7
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 <gi...@hotmail.it>
Authored: Mon Jan 5 11:53:23 2015 +0100
Committer: giacomolm <gi...@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);