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 List<Future<?>>	futures
protected Map<String,RA>	handlers
protected static Logger	LOG
protected Map<String,Supplier<RA>>	suppliers
protected Optional<ThreadPoolTaskExecutor>	tpte

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SyncopeResultHandlerDispatcher(ProvisioningProfile<T,A> profile)

Method Summary

Modifier and Type	Method	Description
void	addHandlerSupplier(String key, Supplier<RA> supplier)
protected RA	nonConcurrentHandler(String key)
protected void	shutdown()
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

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<?>> futures

Constructor Detail

SyncopeResultHandlerDispatcher

protected 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)

shutdown

protected void shutdown()