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 2021/10/12 12:26:58 UTC
[syncope] 01/02: Removing deprecation
This is an automated email from the ASF dual-hosted git repository.
ilgrosso pushed a commit to branch 2_1_X
in repository https://gitbox.apache.org/repos/asf/syncope.git
commit c7a2c7f59f63fd4b26c51bcd9f898477e5192fd6
Author: Francesco Chicchiriccò <il...@apache.org>
AuthorDate: Mon Oct 11 14:50:51 2021 +0200
Removing deprecation
---
.../syncope/core/provisioning/camel/producer/CreateProducer.java | 7 +++----
.../core/provisioning/camel/producer/DeprovisionProducer.java | 6 +++---
.../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(+), 12 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 a8b3cbc..79413e2 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
@@ -63,8 +63,7 @@ public class CreateProducer extends AbstractProducer {
excludedResources);
PropagationReporter reporter = getPropagationTaskExecutor().execute(taskInfos, nullPriorityAsync);
- exchange.getOut().setBody(
- Pair.of(created.getResult().getKey(), reporter.getStatuses()));
+ exchange.getMessage().setBody(Pair.of(created.getResult().getKey(), reporter.getStatuses()));
} else if (actual instanceof AnyTO) {
WorkflowResult<String> created = (WorkflowResult<String>) exchange.getIn().getBody();
@@ -82,7 +81,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 AnyObjectTO ? AnyTypeKind.ANY_OBJECT : AnyTypeKind.GROUP,
@@ -93,7 +92,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 cc91946..8560220 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
@@ -83,7 +83,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:
@@ -96,7 +96,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:
@@ -109,7 +109,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 4bdfbf8..d7f9b44 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
@@ -76,7 +76,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<String> propByRes = new PropagationByResource<>();
propByRes.addAll(ResourceOperation.UPDATE, resources);
@@ -104,7 +104,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 cc20d93..5642758 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
@@ -110,7 +110,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 0fd2b9f..3cc91a7 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
@@ -59,7 +59,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 AnyPatch) {
WorkflowResult<? extends AnyPatch> updated =
(WorkflowResult<? extends AnyPatch>) exchange.getIn().getBody();
@@ -75,7 +75,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()));
}
}
}