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 final List<Future<?>>	futures
protected final Map<String,RA>	handlers
protected static final Logger	LOG
protected final Map<String,Supplier<RA>>	suppliers
protected final Optional<VirtualThreadPoolTaskExecutor>	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()
void	stop()
protected void	submit(Runnable runnable)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final Logger LOG

tpte

protected final Optional<VirtualThreadPoolTaskExecutor> 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 Details

SyncopeResultHandlerDispatcher

protected SyncopeResultHandlerDispatcher(ProvisioningProfile<T,A> profile)

Method Details

addHandlerSupplier

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

nonConcurrentHandler

protected RA nonConcurrentHandler(String key)

submit

protected void submit(Runnable runnable)

stop

public void stop()

shutdown

protected void shutdown()