Class SyncopeResultHandlerDispatcher<T extends ProvisioningTask<?>,A extends ProvisioningActions,RA extends SyncopeResultHandler<T,A>>
- java.lang.Object
-
- org.apache.syncope.core.provisioning.java.pushpull.SyncopeResultHandlerDispatcher<T,A,RA>
-
- Direct Known Subclasses:
PullResultHandlerDispatcher
,PushResultHandlerDispatcher
public abstract class SyncopeResultHandlerDispatcher<T extends ProvisioningTask<?>,A extends ProvisioningActions,RA extends SyncopeResultHandler<T,A>> extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected Optional<ExecutorCompletionService<Void>>
ecs
protected List<Future<Void>>
futures
protected Map<String,RA>
handlers
protected static Logger
LOG
protected Map<String,Supplier<RA>>
suppliers
protected Optional<ThreadPoolTaskExecutor>
tpte
-
Constructor Summary
Constructors Constructor Description SyncopeResultHandlerDispatcher(ProvisioningProfile<T,A> profile)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addHandlerSupplier(String key, Supplier<RA> supplier)
protected void
cleanup()
protected RA
nonConcurrentHandler(String key)
protected void
submit(Runnable runnable)
-
-
-
Field Detail
-
LOG
protected static final Logger LOG
-
tpte
protected final Optional<ThreadPoolTaskExecutor> tpte
-
ecs
protected final Optional<ExecutorCompletionService<Void>> ecs
-
-
Constructor Detail
-
SyncopeResultHandlerDispatcher
public SyncopeResultHandlerDispatcher(ProvisioningProfile<T,A> profile)
-
-