org.apache.syncope.core.provisioning.camel

Class CamelUserProvisioningManager

java.lang.Object

org.apache.syncope.core.provisioning.camel.CamelUserProvisioningManager

All Implemented Interfaces:

ProvisioningManager<UserTO,UserPatch>, UserProvisioningManager

public class CamelUserProvisioningManager
extends Object
implements UserProvisioningManager

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,org.apache.camel.PollingConsumer>	consumerMap
protected SyncopeCamelContext	contextFactory
protected List<String>	knownURIs
protected CamelRouteDAO	routeDAO
protected org.apache.camel.model.RoutesDefinition	routes

Constructor Summary

Constructors

Constructor and Description
CamelUserProvisioningManager()

Method Summary

Modifier and Type	Method and Description
Pair<String,List<PropagationStatus>>	activate(StatusPatch statusPatch, boolean nullPriorityAsync)
void	confirmPasswordReset(String key, String token, String password)
Pair<String,List<PropagationStatus>>	create(UserTO userTO, boolean nullPriorityAsync)
Pair<String,List<PropagationStatus>>	create(UserTO userTO, boolean storePassword, boolean nullPriorityAsync)
Pair<String,List<PropagationStatus>>	create(UserTO userTO, boolean storePassword, boolean disablePwdPolicyCheck, Boolean enabled, Set<String> excludedResources, boolean nullPriorityAsync)
List<PropagationStatus>	delete(String key, boolean nullPriorityAsync)
List<PropagationStatus>	delete(String key, Set<String> excludedResources, boolean nullPriorityAsync)
List<PropagationStatus>	deprovision(String user, Collection<String> resources, boolean nullPriorityAsync)
protected org.apache.camel.PollingConsumer	getConsumer(String uri)
void	internalSuspend(String key)
String	link(UserPatch anyPatch)
List<PropagationStatus>	provision(String key, boolean changePwd, String password, Collection<String> resources, boolean nullPriorityAsync)
Pair<String,List<PropagationStatus>>	reactivate(StatusPatch statusPatch, boolean nullPriorityAsync)
void	requestPasswordReset(String key)
protected void	sendMessage(String uri, Object obj)
protected void	sendMessage(String uri, Object body, Map<String,Object> properties)
Pair<String,List<PropagationStatus>>	suspend(StatusPatch statusPatch, boolean nullPriorityAsync)
String	unlink(UserPatch userPatch)
Pair<UserPatch,List<PropagationStatus>>	update(UserPatch userPatch, boolean nullPriorityAsync)
Pair<UserPatch,List<PropagationStatus>>	update(UserPatch userPatch, ProvisioningReport result, Boolean enabled, Set<String> excludedResources, boolean nullPriorityAsync)
Pair<UserPatch,List<PropagationStatus>>	update(UserPatch userPatch, Set<String> excludedResources, boolean nullPriorityAsync)

Methods inherited from class java.lang.Object

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

Field Detail

routeDAO

@Autowired
protected CamelRouteDAO routeDAO

contextFactory

@Autowired
protected SyncopeCamelContext contextFactory

routes

protected org.apache.camel.model.RoutesDefinition routes

consumerMap

protected final Map<String,org.apache.camel.PollingConsumer> consumerMap

knownURIs

protected final List<String> knownURIs

Constructor Detail

CamelUserProvisioningManager

public CamelUserProvisioningManager()

Method Detail

create

public Pair<String,List<PropagationStatus>> create(UserTO userTO,
                                                   boolean nullPriorityAsync)

Specified by:

create in interface ProvisioningManager<UserTO,UserPatch>

create

public Pair<String,List<PropagationStatus>> create(UserTO userTO,
                                                   boolean storePassword,
                                                   boolean nullPriorityAsync)

Specified by:

create in interface UserProvisioningManager

create

@Transactional(propagation=REQUIRES_NEW)
public Pair<String,List<PropagationStatus>> create(UserTO userTO,
                                                                                            boolean storePassword,
                                                                                            boolean disablePwdPolicyCheck,
                                                                                            Boolean enabled,
                                                                                            Set<String> excludedResources,
                                                                                            boolean nullPriorityAsync)

Specified by:

create in interface UserProvisioningManager

update

public Pair<UserPatch,List<PropagationStatus>> update(UserPatch userPatch,
                                                      boolean nullPriorityAsync)

Specified by:

update in interface ProvisioningManager<UserTO,UserPatch>

update

public Pair<UserPatch,List<PropagationStatus>> update(UserPatch userPatch,
                                                      Set<String> excludedResources,
                                                      boolean nullPriorityAsync)

Specified by:

update in interface ProvisioningManager<UserTO,UserPatch>

delete

public List<PropagationStatus> delete(String key,
                                      boolean nullPriorityAsync)

Specified by:

delete in interface ProvisioningManager<UserTO,UserPatch>

delete

@Transactional(propagation=REQUIRES_NEW)
public List<PropagationStatus> delete(String key,
                                                                               Set<String> excludedResources,
                                                                               boolean nullPriorityAsync)

Specified by:

delete in interface ProvisioningManager<UserTO,UserPatch>

unlink

public String unlink(UserPatch userPatch)

Specified by:

unlink in interface ProvisioningManager<UserTO,UserPatch>

activate

public Pair<String,List<PropagationStatus>> activate(StatusPatch statusPatch,
                                                     boolean nullPriorityAsync)

Specified by:

activate in interface UserProvisioningManager

reactivate

public Pair<String,List<PropagationStatus>> reactivate(StatusPatch statusPatch,
                                                       boolean nullPriorityAsync)

Specified by:

reactivate in interface UserProvisioningManager

suspend

public Pair<String,List<PropagationStatus>> suspend(StatusPatch statusPatch,
                                                    boolean nullPriorityAsync)

Specified by:

suspend in interface UserProvisioningManager

link

public String link(UserPatch anyPatch)

Specified by:

link in interface ProvisioningManager<UserTO,UserPatch>

provision

public List<PropagationStatus> provision(String key,
                                         boolean changePwd,
                                         String password,
                                         Collection<String> resources,
                                         boolean nullPriorityAsync)

Specified by:

provision in interface UserProvisioningManager

deprovision

public List<PropagationStatus> deprovision(String user,
                                           Collection<String> resources,
                                           boolean nullPriorityAsync)

Specified by:

deprovision in interface ProvisioningManager<UserTO,UserPatch>

update

@Transactional(propagation=REQUIRES_NEW)
public Pair<UserPatch,List<PropagationStatus>> update(UserPatch userPatch,
                                                                                               ProvisioningReport result,
                                                                                               Boolean enabled,
                                                                                               Set<String> excludedResources,
                                                                                               boolean nullPriorityAsync)

Specified by:

update in interface UserProvisioningManager

internalSuspend

public void internalSuspend(String key)

Specified by:

internalSuspend in interface UserProvisioningManager

requestPasswordReset

public void requestPasswordReset(String key)

Specified by:

requestPasswordReset in interface UserProvisioningManager

confirmPasswordReset

public void confirmPasswordReset(String key,
                                 String token,
                                 String password)

Specified by:

confirmPasswordReset in interface UserProvisioningManager

sendMessage

protected void sendMessage(String uri,
                           Object obj)

sendMessage

protected void sendMessage(String uri,
                           Object body,
                           Map<String,Object> properties)

getConsumer

protected org.apache.camel.PollingConsumer getConsumer(String uri)