Package org.apache.syncope.core.provisioning.java.pushpull

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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static final Logger LOG

tpte

protected final Optional<ThreadPoolTaskExecutor> tpte

ecs

protected final Optional<ExecutorCompletionService<Void>> ecs

suppliers

protected final Map<String,Supplier<RA extends SyncopeResultHandler<T,A>>> suppliers

handlers

protected final Map<String,RA extends SyncopeResultHandler<T,A>> handlers

futures

protected final List<Future<Void>> futures

Constructor Detail

SyncopeResultHandlerDispatcher

public SyncopeResultHandlerDispatcher(ProvisioningProfile<T,A> profile)

Method Detail

addHandlerSupplier

public void addHandlerSupplier(String key,
                               Supplier<RA> supplier)

nonConcurrentHandler

protected RA nonConcurrentHandler(String key)

submit

protected void submit(Runnable runnable)

cleanup

protected void cleanup()