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

Class AbstractPullResultHandler

java.lang.Object

org.apache.syncope.core.provisioning.java.pushpull.AbstractSyncopeResultHandler<PullTask,InboundActions>

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

All Implemented Interfaces:

AnyPullResultHandler, SyncopePullResultHandler, SyncopeResultHandler<PullTask,InboundActions>, SyncResultsHandler

Direct Known Subclasses:

DefaultAnyObjectPullResultHandler, DefaultGroupPullResultHandler, DefaultUserPullResultHandler

public abstract class AbstractPullResultHandler
extends AbstractSyncopeResultHandler<PullTask,InboundActions>
implements AnyPullResultHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyTypeDAO	anyTypeDAO
protected AuditManager	auditManager
protected ConnObjectUtils	connObjectUtils
protected EntityFactory	entityFactory
protected final Map<String,Optional<String>>	gManagers
protected InboundMatcher	inboundMatcher
protected NotificationManager	notificationManager
protected RemediationDAO	remediationDAO
protected TaskDAO	taskDAO
protected final Map<String,Optional<String>>	uManagers

Fields inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractSyncopeResultHandler

anyObjectDataBinder, anyUtilsFactory, awfAdapter, groupDataBinder, gwfAdapter, LOG, profile, propagationManager, securityProperties, stopRequested, taskExecutor, userDataBinder, uwfAdapter

Constructor Summary

Constructors

Constructor	Description
AbstractPullResultHandler()

Method Summary

Modifier and Type	Method	Description
protected void	createRemediationIfNeeded(AnyUR anyUR, SyncDelta delta, ProvisioningReport result)
protected OpEvent.Outcome	delete(SyncDelta delta, InboundMatch match, Provision provision)
protected OpEvent.Outcome	deprovision(MatchingRule matchingRule, SyncDelta delta, InboundMatch match, Provision provision)
protected abstract AnyTO	doCreate(AnyCR anyCR, SyncDelta delta)
protected OpEvent.Outcome	doHandle(SyncDelta delta, Provision provision, AnyTypeKind anyTypeKind)	Look into SyncDelta and take necessary profile.getActions() (create / update / delete) on any object(s).
protected abstract AnyUR	doUpdate(AnyTO before, AnyUR anyUR, SyncDelta delta, ProvisioningReport result)
protected void	end(String anyType, String event, OpEvent.Outcome result, Object before, Object output, SyncDelta delta, Object... furtherInput)
protected abstract String	getName(AnyCR anyCR)
protected abstract String	getName(AnyTO anyTO)
boolean	handle(SyncDelta delta)
protected OpEvent.Outcome	handleAny(SyncDelta delta, InboundMatch match, AnyTypeKind anyTypeKind, Provision provision)
protected OpEvent.Outcome	handleLinkedAccount(SyncDelta delta, InboundMatch match, Provision provision)
protected OpEvent.Outcome	ignore(SyncDelta delta, InboundMatch match, Provision provision, boolean matching, String... message)
protected OpEvent.Outcome	link(SyncDelta delta, InboundMatch match, Provision provision, boolean unlink)
protected OpEvent.Outcome	provision(UnmatchingRule rule, SyncDelta delta, AnyTypeKind anyTypeKind, Provision provision)
protected abstract ProvisioningManager<?,?>	provisioningManager()
void	setManagers()
protected void	throwIgnoreProvisionException(SyncDelta delta, Exception exception)
protected OpEvent.Outcome	update(SyncDelta delta, InboundMatch match, Provision provision)

Methods inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractSyncopeResultHandler

anyUtils, getAnyTO, setProfile, stop, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.syncope.core.provisioning.api.pushpull.SyncopeResultHandler

setProfile, stop

Field Details

inboundMatcher

@Autowired
protected InboundMatcher inboundMatcher

notificationManager

@Autowired
protected NotificationManager notificationManager

auditManager

@Autowired
protected AuditManager auditManager

connObjectUtils

@Autowired
protected ConnObjectUtils connObjectUtils

anyTypeDAO

@Autowired
protected AnyTypeDAO anyTypeDAO

taskDAO

@Autowired
protected TaskDAO taskDAO

remediationDAO

@Autowired
protected RemediationDAO remediationDAO

entityFactory

@Autowired
protected EntityFactory entityFactory

uManagers

protected final Map<String,Optional<String>> uManagers

gManagers

protected final Map<String,Optional<String>> gManagers

Constructor Details

AbstractPullResultHandler

public AbstractPullResultHandler()

Method Details

getName

protected abstract String getName(AnyTO anyTO)

getName

protected abstract String getName(AnyCR anyCR)

provisioningManager

protected abstract ProvisioningManager<?,?> provisioningManager()

doCreate

protected abstract AnyTO doCreate(AnyCR anyCR,
 SyncDelta delta)

doUpdate

protected abstract AnyUR doUpdate(AnyTO before,
 AnyUR anyUR,
 SyncDelta delta,
 ProvisioningReport result)

handle

@Transactional(rollbackFor=java.lang.Throwable.class,
               propagation=REQUIRES_NEW)
public boolean handle(SyncDelta delta)

Specified by:

handle in interface SyncopePullResultHandler

Specified by:

handle in interface SyncResultsHandler

throwIgnoreProvisionException

protected void throwIgnoreProvisionException(SyncDelta delta,
 Exception exception)

provision

protected OpEvent.Outcome provision(UnmatchingRule rule,
 SyncDelta delta,
 AnyTypeKind anyTypeKind,
 Provision provision)
                             throws JobExecutionException

Throws:

JobExecutionException

update

protected OpEvent.Outcome update(SyncDelta delta,
 InboundMatch match,
 Provision provision)
                          throws JobExecutionException

Throws:

JobExecutionException

deprovision

protected OpEvent.Outcome deprovision(MatchingRule matchingRule,
 SyncDelta delta,
 InboundMatch match,
 Provision provision)
                               throws JobExecutionException

Throws:

JobExecutionException

link

protected OpEvent.Outcome link(SyncDelta delta,
 InboundMatch match,
 Provision provision,
 boolean unlink)
                        throws JobExecutionException

Throws:

JobExecutionException

delete

protected OpEvent.Outcome delete(SyncDelta delta,
 InboundMatch match,
 Provision provision)

ignore

protected OpEvent.Outcome ignore(SyncDelta delta,
 InboundMatch match,
 Provision provision,
 boolean matching,
 String... message)

handleAny

protected OpEvent.Outcome handleAny(SyncDelta delta,
 InboundMatch match,
 AnyTypeKind anyTypeKind,
 Provision provision)
                             throws JobExecutionException

Throws:

JobExecutionException

handleLinkedAccount

protected OpEvent.Outcome handleLinkedAccount(SyncDelta delta,
 InboundMatch match,
 Provision provision)
                                       throws JobExecutionException

Throws:

JobExecutionException

doHandle

protected OpEvent.Outcome doHandle(SyncDelta delta,
 Provision provision,
 AnyTypeKind anyTypeKind)
                            throws JobExecutionException

Look into SyncDelta and take necessary profile.getActions() (create / update / delete) on any object(s).

Parameters:

delta - returned by the underlying profile.getConnector()

provision - provisioning info

anyTypeKind - any type kind

Returns:

if handle was successful or not

Throws:

JobExecutionException - in case of pull failure.

end

protected void end(String anyType,
 String event,
 OpEvent.Outcome result,
 Object before,
 Object output,
 SyncDelta delta,
 Object... furtherInput)

createRemediationIfNeeded

protected void createRemediationIfNeeded(AnyUR anyUR,
 SyncDelta delta,
 ProvisioningReport result)

setManagers

@Transactional(propagation=REQUIRES_NEW)
public void setManagers()

Specified by:

setManagers in interface AnyPullResultHandler