diff --git a/core/provisioning-java/src/main/java/org/apache/syncope/core/provisioning/java/data/TaskDataBinderImpl.java b/core/provisioning-java/src/main/java/org/apache/syncope/core/provisioning/java/data/TaskDataBinderImpl.java
index fb6202645b8..f6e876c3ee8 100644
--- a/core/provisioning-java/src/main/java/org/apache/syncope/core/provisioning/java/data/TaskDataBinderImpl.java
+++ b/core/provisioning-java/src/main/java/org/apache/syncope/core/provisioning/java/data/TaskDataBinderImpl.java
@@ -125,7 +125,7 @@ protected void fill(final ProvisioningTask<?> provisioningTask, final Provisioni
 
             Implementation jobDelegate = pushTaskTO.getJobDelegate() == null
                     ? implementationDAO.findByType(IdRepoImplementationType.TASKJOB_DELEGATE).stream().
-                            filter(impl -> PushJobDelegate.class.getName().equals(impl.getBody())).
+                            filter(impl -> PushJobDelegate.class.getSimpleName().equals(impl.getKey())).
                             findFirst().orElse(null)
                     : implementationDAO.find(pushTaskTO.getJobDelegate());
             if (jobDelegate == null) {
@@ -164,7 +164,7 @@ protected void fill(final ProvisioningTask<?> provisioningTask, final Provisioni
 
             Implementation jobDelegate = pullTaskTO.getJobDelegate() == null
                     ? implementationDAO.findByType(IdRepoImplementationType.TASKJOB_DELEGATE).stream().
-                            filter(impl -> PullJobDelegate.class.getName().equals(impl.getBody())).
+                            filter(impl -> PullJobDelegate.class.getSimpleName().equals(impl.getKey())).
                             findFirst().orElse(null)
                     : implementationDAO.find(pullTaskTO.getJobDelegate());
             if (jobDelegate == null) {