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

Class InstrumentedPriorityPropagationTaskExecutor

java.lang.Object

org.apache.syncope.core.provisioning.java.propagation.AbstractPropagationTaskExecutor

org.apache.syncope.core.provisioning.java.propagation.PriorityPropagationTaskExecutor

org.apache.syncope.core.provisioning.java.propagation.InstrumentedPriorityPropagationTaskExecutor

All Implemented Interfaces:

PropagationTaskExecutor

public class InstrumentedPriorityPropagationTaskExecutor
extends PriorityPropagationTaskExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.micrometer.core.instrument.MeterRegistry	meterRegistry

Fields inherited from class org.apache.syncope.core.provisioning.java.propagation.PriorityPropagationTaskExecutor

taskExecutor

Fields inherited from class org.apache.syncope.core.provisioning.java.propagation.AbstractPropagationTaskExecutor

anyUtilsFactory, auditManager, connectorManager, connObjectUtils, LOG, notificationManager, outboundMatcher, perContextActions, plainSchemaDAO, publisher, resourceDAO, retryTemplates, taskDAO, taskDataBinder, taskUtilsFactory, validator

Constructor Summary

Constructors

Constructor

Description

InstrumentedPriorityPropagationTaskExecutor(ConnectorManager connectorManager, ConnObjectUtils connObjectUtils, TaskDAO taskDAO, ExternalResourceDAO resourceDAO, PlainSchemaDAO plainSchemaDAO, NotificationManager notificationManager, AuditManager auditManager, TaskDataBinder taskDataBinder, AnyUtilsFactory anyUtilsFactory, TaskUtilsFactory taskUtilsFactory, OutboundMatcher outboundMatcher, PlainAttrValidationManager validator, ApplicationEventPublisher publisher, AsyncTaskExecutor taskExecutor, io.micrometer.core.instrument.MeterRegistry meterRegistry)

Method Summary

Modifier and Type	Method	Description
PropagationReporter	execute(Collection<PropagationTaskInfo> taskInfos, boolean nullPriorityAsync, String executor)	Execute the given collection of tasks.

Methods inherited from class org.apache.syncope.core.provisioning.java.propagation.PriorityPropagationTaskExecutor

failed, newPropagationTaskCallable

Methods inherited from class org.apache.syncope.core.provisioning.java.propagation.AbstractPropagationTaskExecutor

checkMandatoryMissing, createOrUpdate, delete, doCreate, doExecute, doUpdate, doUpdateDelta, execute, expireRetryTemplate, getPropagationActions, getRemoteObject, getRemoteObject, hasToBeregistered, isFetchRemoteObj, rejected, retryTemplate

Methods inherited from class java.lang.Object

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

Field Details

meterRegistry

protected final io.micrometer.core.instrument.MeterRegistry meterRegistry

Constructor Details

InstrumentedPriorityPropagationTaskExecutor

public InstrumentedPriorityPropagationTaskExecutor(ConnectorManager connectorManager,
 ConnObjectUtils connObjectUtils,
 TaskDAO taskDAO,
 ExternalResourceDAO resourceDAO,
 PlainSchemaDAO plainSchemaDAO,
 NotificationManager notificationManager,
 AuditManager auditManager,
 TaskDataBinder taskDataBinder,
 AnyUtilsFactory anyUtilsFactory,
 TaskUtilsFactory taskUtilsFactory,
 OutboundMatcher outboundMatcher,
 PlainAttrValidationManager validator,
 ApplicationEventPublisher publisher,
 AsyncTaskExecutor taskExecutor,
 io.micrometer.core.instrument.MeterRegistry meterRegistry)

Method Details

execute

public PropagationReporter execute(Collection<PropagationTaskInfo> taskInfos,
 boolean nullPriorityAsync,
 String executor)

Description copied from interface: PropagationTaskExecutor

Execute the given collection of tasks. The process is interrupted as soon as the result of the communication with a resource with non-null priority is in error.

Specified by:

execute in interface PropagationTaskExecutor

Overrides:

execute in class PriorityPropagationTaskExecutor

Parameters:

taskInfos - to be execute, in given order

nullPriorityAsync - asynchronously executes tasks related to resources with no priority

executor - the executor of this task

Returns:

reporter to report propagation execution status