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:

SyncopePullResultHandler, SyncopeResultHandler<PullTask,InboundActions>, SyncResultsHandler

Direct Known Subclasses:

DefaultAnyObjectPullResultHandler, DefaultGroupPullResultHandler, DefaultUserPullResultHandler

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

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyTypeDAO	anyTypeDAO
protected AuditManager	auditManager
protected ConnObjectUtils	connObjectUtils
protected EntityFactory	entityFactory
protected InboundMatcher	inboundMatcher
protected NotificationManager	notificationManager
protected RemediationDAO	remediationDAO
protected TaskDAO	taskDAO
protected UserDAO	userDAO

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 static OpEvent.Outcome	and(OpEvent.Outcome left, OpEvent.Outcome right)
protected void	createRemediation(String anyType, String anyKey, AnyCR anyCR, AnyUR anyUR, ProvisioningReport result, SyncDelta delta)
protected void	createRemediationIfNeeded(AnyUR anyUR, SyncDelta delta, ProvisioningReport result)
protected OpEvent.Outcome	delete(SyncDelta delta, List<InboundMatch> matches, Provision provision)
protected OpEvent.Outcome	deprovision(MatchingRule matchingRule, SyncDelta delta, List<InboundMatch> matches, 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)
protected abstract ProvisioningManager<?,?>	getProvisioningManager()
boolean	handle(SyncDelta delta)
protected OpEvent.Outcome	handleAnys(SyncDelta delta, List<InboundMatch> matches, AnyTypeKind anyTypeKind, Provision provision)
protected OpEvent.Outcome	handleLinkedAccounts(SyncDelta delta, List<InboundMatch> matches, Provision provision)
protected OpEvent.Outcome	ignore(SyncDelta delta, List<InboundMatch> matches, Provision provision, boolean matching, String... message)
protected OpEvent.Outcome	link(SyncDelta delta, List<InboundMatch> matches, Provision provision, boolean unlink)
protected OpEvent.Outcome	provision(UnmatchingRule rule, SyncDelta delta, AnyTypeKind anyTypeKind, Provision provision)
protected void	throwIgnoreProvisionException(SyncDelta delta, Exception exception)
protected OpEvent.Outcome	update(SyncDelta delta, List<InboundMatch> matches, Provision provision)

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

getAnyTO, getAnyUtils, 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

userDAO

@Autowired
protected UserDAO userDAO

anyTypeDAO

@Autowired
protected AnyTypeDAO anyTypeDAO

taskDAO

@Autowired
protected TaskDAO taskDAO

remediationDAO

@Autowired
protected RemediationDAO remediationDAO

entityFactory

@Autowired
protected EntityFactory entityFactory

Constructor Details

AbstractPullResultHandler

public AbstractPullResultHandler()

Method Details

and

protected static OpEvent.Outcome and(OpEvent.Outcome left,
 OpEvent.Outcome right)

getName

protected abstract String getName(AnyTO anyTO)

getName

protected abstract String getName(AnyCR anyCR)

getProvisioningManager

protected abstract ProvisioningManager<?,?> getProvisioningManager()

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,
 List<InboundMatch> matches,
 Provision provision)
                          throws JobExecutionException

Throws:

JobExecutionException

deprovision

protected OpEvent.Outcome deprovision(MatchingRule matchingRule,
 SyncDelta delta,
 List<InboundMatch> matches,
 Provision provision)
                               throws JobExecutionException

Throws:

JobExecutionException

link

protected OpEvent.Outcome link(SyncDelta delta,
 List<InboundMatch> matches,
 Provision provision,
 boolean unlink)
                        throws JobExecutionException

Throws:

JobExecutionException

delete

protected OpEvent.Outcome delete(SyncDelta delta,
 List<InboundMatch> matches,
 Provision provision)

ignore

protected OpEvent.Outcome ignore(SyncDelta delta,
 List<InboundMatch> matches,
 Provision provision,
 boolean matching,
 String... message)

handleAnys

protected OpEvent.Outcome handleAnys(SyncDelta delta,
 List<InboundMatch> matches,
 AnyTypeKind anyTypeKind,
 Provision provision)
                              throws JobExecutionException

Throws:

JobExecutionException

handleLinkedAccounts

protected OpEvent.Outcome handleLinkedAccounts(SyncDelta delta,
 List<InboundMatch> matches,
 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)

createRemediation

protected void createRemediation(String anyType,
 String anyKey,
 AnyCR anyCR,
 AnyUR anyUR,
 ProvisioningReport result,
 SyncDelta delta)