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
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected final io.micrometer.core.instrument.MeterRegistryFields inherited from class org.apache.syncope.core.provisioning.java.propagation.PriorityPropagationTaskExecutor
taskExecutorFields 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
ConstructorsConstructorDescriptionInstrumentedPriorityPropagationTaskExecutor(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 TypeMethodDescriptionexecute(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, newPropagationTaskCallableMethods 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
-
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:PropagationTaskExecutorExecute 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:
executein interfacePropagationTaskExecutor- Overrides:
executein classPriorityPropagationTaskExecutor- Parameters:
taskInfos- to be execute, in given ordernullPriorityAsync- asynchronously executes tasks related to resources with no priorityexecutor- the executor of this task- Returns:
- reporter to report propagation execution status
-