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 2019/09/15 10:23:05 UTC
[syncope] branch master updated: Remove usage of deprecated method
This is an automated email from the ASF dual-hosted git repository.
ilgrosso pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/syncope.git
The following commit(s) were added to refs/heads/master by this push:
new ab30b54 Remove usage of deprecated method
ab30b54 is described below
commit ab30b54e852ac6372176b43fcbf427aefa19b443
Author: Francesco Chicchiriccò <il...@apache.org>
AuthorDate: Sun Sep 15 12:22:53 2019 +0200
Remove usage of deprecated method
---
.../syncope/core/provisioning/camel/producer/CreateProducer.java | 6 +++---
.../core/provisioning/camel/producer/DeprovisionProducer.java | 6 +++---
.../syncope/core/provisioning/camel/producer/ProvisionProducer.java | 4 ++--
.../syncope/core/provisioning/camel/producer/StatusProducer.java | 2 +-
.../syncope/core/provisioning/camel/producer/UpdateProducer.java | 4 ++--
5 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/CreateProducer.java b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/CreateProducer.java
index 4f86cff..c75e7c7 100644
--- a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/CreateProducer.java
+++ b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/CreateProducer.java
@@ -61,7 +61,7 @@ public class CreateProducer extends AbstractProducer {
excludedResources);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(
+ exchange.getMessage().setBody(
Pair.of(created.getResult().getKey(), reporter.getStatuses()));
} else if (actual instanceof AnyCR) {
WorkflowResult<String> created = (WorkflowResult<String>) exchange.getIn().getBody();
@@ -80,7 +80,7 @@ public class CreateProducer extends AbstractProducer {
excludedResources);
getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(Pair.of(created.getResult(), null));
+ exchange.getMessage().setBody(Pair.of(created.getResult(), null));
} else {
List<PropagationTaskInfo> taskInfos = getPropagationManager().getCreateTasks(
actual instanceof AnyObjectCR ? AnyTypeKind.ANY_OBJECT : AnyTypeKind.GROUP,
@@ -91,7 +91,7 @@ public class CreateProducer extends AbstractProducer {
excludedResources);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(Pair.of(created.getResult(), reporter.getStatuses()));
+ exchange.getMessage().setBody(Pair.of(created.getResult(), reporter.getStatuses()));
}
}
}
diff --git a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/DeprovisionProducer.java b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/DeprovisionProducer.java
index 2ff8dd5..1e331a5 100644
--- a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/DeprovisionProducer.java
+++ b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/DeprovisionProducer.java
@@ -73,7 +73,7 @@ public class DeprovisionProducer extends AbstractProducer {
userDAO.findAllResourceKeys(key).stream().
filter(resource -> !resources.contains(resource)).collect(Collectors.toList()));
propagationReporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(propagationReporter.getStatuses());
+ exchange.getMessage().setBody(propagationReporter.getStatuses());
break;
case GROUP:
@@ -85,7 +85,7 @@ public class DeprovisionProducer extends AbstractProducer {
groupDAO.findAllResourceKeys(key).stream().
filter(resource -> !resources.contains(resource)).collect(Collectors.toList()));
propagationReporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(propagationReporter.getStatuses());
+ exchange.getMessage().setBody(propagationReporter.getStatuses());
break;
case ANY_OBJECT:
@@ -97,7 +97,7 @@ public class DeprovisionProducer extends AbstractProducer {
anyObjectDAO.findAllResourceKeys(key).stream().
filter(resource -> !resources.contains(resource)).collect(Collectors.toList()));
propagationReporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(propagationReporter.getStatuses());
+ exchange.getMessage().setBody(propagationReporter.getStatuses());
break;
default:
diff --git a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/ProvisionProducer.java b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/ProvisionProducer.java
index abfc4cf..c6e9312 100644
--- a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/ProvisionProducer.java
+++ b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/ProvisionProducer.java
@@ -72,7 +72,7 @@ public class ProvisionProducer extends AbstractProducer {
List<PropagationTaskInfo> taskInfos = getPropagationManager().getUserUpdateTasks(wfResult, changePwd, null);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(reporter.getStatuses());
+ exchange.getMessage().setBody(reporter.getStatuses());
} else {
PropagationByResource propByRes = new PropagationByResource();
propByRes.addAll(ResourceOperation.UPDATE, resources);
@@ -92,7 +92,7 @@ public class ProvisionProducer extends AbstractProducer {
null);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(reporter.getStatuses());
+ exchange.getMessage().setBody(reporter.getStatuses());
}
}
}
diff --git a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/StatusProducer.java b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/StatusProducer.java
index 176cbb6..e146dcc 100644
--- a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/StatusProducer.java
+++ b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/StatusProducer.java
@@ -100,7 +100,7 @@ public class StatusProducer extends AbstractProducer {
null);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(Pair.of(updated.getResult(), reporter.getStatuses()));
+ exchange.getMessage().setBody(Pair.of(updated.getResult(), reporter.getStatuses()));
}
}
}
diff --git a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/UpdateProducer.java b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/UpdateProducer.java
index 11c5e28..533e832 100644
--- a/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/UpdateProducer.java
+++ b/ext/camel/provisioning-camel/src/main/java/org/apache/syncope/core/provisioning/camel/producer/UpdateProducer.java
@@ -58,7 +58,7 @@ public class UpdateProducer extends AbstractProducer {
}
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(Pair.of(updated.getResult().getLeft(), reporter.getStatuses()));
+ exchange.getMessage().setBody(Pair.of(updated.getResult().getLeft(), reporter.getStatuses()));
} else if (actual instanceof AnyUR) {
WorkflowResult<? extends AnyUR> updated =
(WorkflowResult<? extends AnyUR>) exchange.getIn().getBody();
@@ -73,7 +73,7 @@ public class UpdateProducer extends AbstractProducer {
excludedResources);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(Pair.of(updated.getResult(), reporter.getStatuses()));
+ exchange.getMessage().setBody(Pair.of(updated.getResult(), reporter.getStatuses()));
}
}
}