Class ProvisioningEngineImpl

java.lang.Object

com.tremolosecurity.provisioning.core.ProvisioningEngineImpl

All Implemented Interfaces:

ProvisioningEngine

public class ProvisioningEngineImpl
extends Object
implements ProvisioningEngine

Author:

Tremolo Security Inc.

Constructor Summary

Constructors

Constructor	Description
ProvisioningEngineImpl(ConfigManager cfgMgr)	Default constructor

Method Summary

Modifier and Type	Method	Description
void	addDynamicTarget(ConfigManager cfgMgr, TargetType targetCfg)
void	addDynamicWorkflow(WorkflowType wft)
void	addMessageListener(MessageListenerType mlt)
void	addNewJob(HashSet<String> jobKeys, JobType jobType)
void	clearDLQ()
Object	decryptObject(EncryptedMessage msg)
void	deleteJob(String jobName, String groupName)
void	deleteRemovedJobs(HashSet<String> jobKeys, String groupName)
void	deleteRemovedLocalJobs(HashSet<String> jobKeys, String groupName)
void	dlqMessage(jakarta.jms.TextMessage m)
void	doApproval(int id, String userID, boolean approved, String reason)
EncryptedMessage	encryptObject(Object o)
void	endBroker()
void	enqueue(WorkflowHolder wfHolder)
void	enqueue(WorkflowHolder wfHolder, int num)
void	execute()
ArrayList<String>	getApproverAttributes()
org.hibernate.SessionFactory	getHibernateSessionFactory()
String	getLocalhost()
String	getSmtpFrom()
String	getSmtpHost()
String	getSmtpPassword()
int	getSmtpPort()
String	getSmtpSubject()
String	getSmtpUser()
String	getSocksProxyHost()
int	getSocksProxyPort()
ProvisioningTarget	getTarget(String name)	Retrieves a provisioning target by its name as configured in the administration system
JMSSessionHolder	getTaskMessageProducer()
ArrayList<String>	getUserAttrbiutes()
String	getUserIDAttribute()
Workflow	getWorkFlow(String name)
Workflow	getWorkFlow(String name, User user)
Workflow	getWorkflowCopy(String name)
void	initListeners()
void	initMessageConsumers()
void	initReports()
void	initScheduler()
void	initWorkFlows()	Initializes the configured workflows from their XML source
boolean	isInternalQueue()
boolean	isSmtpTLS()
boolean	isUseSOCKSProxy()
void	logAction(String target, boolean isEntry, ProvisioningUtil.ActionType actionType, int approval, Workflow wf, String attribute, String val)
void	rebuildHibernate()
void	reEnQueue(jakarta.jms.TextMessage tm, int numOfTries, JMSSessionHolder session)
void	reEnQueueTask(jakarta.jms.TextMessage tm, int numOfTries)
void	removeDynamicWorkflow(String name)
void	removeMessageListener(String name)
void	removeTarget(String name)
void	replaceDynamicWorkflow(WorkflowType wft)
void	replaceTarget(ConfigManager cfgMgr, TargetType targetCfg)
void	returnQueueConnection(jakarta.jms.Connection con)
void	sendNotification(String email, String msgTxt, User user)
void	sendNotification(String email, String msgTxt, User user, String contentType)
void	sendNotification(String email, String msgTxt, String subject, User user)
void	sendNotification(String email, String msgTxt, String subject, User user, String contentType)

Methods inherited from class java.lang.Object

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

Constructor Details

ProvisioningEngineImpl

public ProvisioningEngineImpl(ConfigManager cfgMgr)
                       throws ProvisioningException

Default constructor

Parameters:

cfgMgr -

Throws:

ProvisioningException

Method Details

initReports

public void initReports()
                 throws ProvisioningException

Specified by:

initReports in interface ProvisioningEngine

Throws:

ProvisioningException

initWorkFlows

public void initWorkFlows()
                   throws ProvisioningException

Description copied from interface: ProvisioningEngine

Initializes the configured workflows from their XML source

Specified by:

initWorkFlows in interface ProvisioningEngine

Throws:

ProvisioningException

addDynamicWorkflow

public void addDynamicWorkflow(WorkflowType wft)
                        throws ProvisioningException

Specified by:

addDynamicWorkflow in interface ProvisioningEngine

Throws:

ProvisioningException

replaceDynamicWorkflow

public void replaceDynamicWorkflow(WorkflowType wft)
                            throws ProvisioningException

Specified by:

replaceDynamicWorkflow in interface ProvisioningEngine

Throws:

ProvisioningException

removeDynamicWorkflow

public void removeDynamicWorkflow(String name)
                           throws ProvisioningException

Specified by:

removeDynamicWorkflow in interface ProvisioningEngine

Throws:

ProvisioningException

addDynamicTarget

public void addDynamicTarget(ConfigManager cfgMgr,
 TargetType targetCfg)
                      throws ProvisioningException

Specified by:

addDynamicTarget in interface ProvisioningEngine

Throws:

ProvisioningException

removeTarget

public void removeTarget(String name)
                  throws ProvisioningException

Specified by:

removeTarget in interface ProvisioningEngine

Throws:

ProvisioningException

replaceTarget

public void replaceTarget(ConfigManager cfgMgr,
 TargetType targetCfg)
                   throws ProvisioningException

Specified by:

replaceTarget in interface ProvisioningEngine

Throws:

ProvisioningException

getTarget

public ProvisioningTarget getTarget(String name)
                             throws ProvisioningException

Description copied from interface: ProvisioningEngine

Retrieves a provisioning target by its name as configured in the administration system

Specified by:

getTarget in interface ProvisioningEngine

Parameters:

name - The name of the target

Returns:

The target implementation class

Throws:

ProvisioningException - Thrown if no target exists with that name

getWorkFlow

public Workflow getWorkFlow(String name,
 User user)
                     throws ProvisioningException

Specified by:

getWorkFlow in interface ProvisioningEngine

Parameters:

name -

user -

Returns:

Throws:

ProvisioningException

getWorkFlow

public Workflow getWorkFlow(String name)
                     throws ProvisioningException

Specified by:

getWorkFlow in interface ProvisioningEngine

Throws:

ProvisioningException

getWorkflowCopy

public Workflow getWorkflowCopy(String name)
                         throws ProvisioningException

Specified by:

getWorkflowCopy in interface ProvisioningEngine

Throws:

ProvisioningException

doApproval

public void doApproval(int id,
 String userID,
 boolean approved,
 String reason)
                throws ProvisioningException

Specified by:

doApproval in interface ProvisioningEngine

Throws:

ProvisioningException

getUserIDAttribute

public String getUserIDAttribute()

Specified by:

getUserIDAttribute in interface ProvisioningEngine

getApproverAttributes

public ArrayList<String> getApproverAttributes()

Specified by:

getApproverAttributes in interface ProvisioningEngine

getUserAttrbiutes

public ArrayList<String> getUserAttrbiutes()

Specified by:

getUserAttrbiutes in interface ProvisioningEngine

logAction

public void logAction(String target,
 boolean isEntry,
 ProvisioningUtil.ActionType actionType,
 int approval,
 Workflow wf,
 String attribute,
 String val)
               throws ProvisioningException

Specified by:

logAction in interface ProvisioningEngine

Throws:

ProvisioningException

sendNotification

public void sendNotification(String email,
 String msgTxt,
 User user)
                      throws Exception

Specified by:

sendNotification in interface ProvisioningEngine

Throws:

Exception

sendNotification

public void sendNotification(String email,
 String msgTxt,
 User user,
 String contentType)
                      throws Exception

Specified by:

sendNotification in interface ProvisioningEngine

Throws:

Exception

sendNotification

public void sendNotification(String email,
 String msgTxt,
 String subject,
 User user)
                      throws Exception

Specified by:

sendNotification in interface ProvisioningEngine

Throws:

Exception

sendNotification

public void sendNotification(String email,
 String msgTxt,
 String subject,
 User user,
 String contentType)
                      throws Exception

Specified by:

sendNotification in interface ProvisioningEngine

Throws:

Exception

getSmtpHost

public String getSmtpHost()

Specified by:

getSmtpHost in interface ProvisioningEngine

getSmtpPort

public int getSmtpPort()

Specified by:

getSmtpPort in interface ProvisioningEngine

getSmtpUser

public String getSmtpUser()

Specified by:

getSmtpUser in interface ProvisioningEngine

getSmtpPassword

public String getSmtpPassword()

Specified by:

getSmtpPassword in interface ProvisioningEngine

getSmtpSubject

public String getSmtpSubject()

Specified by:

getSmtpSubject in interface ProvisioningEngine

getSmtpFrom

public String getSmtpFrom()

Specified by:

getSmtpFrom in interface ProvisioningEngine

isSmtpTLS

public boolean isSmtpTLS()

Specified by:

isSmtpTLS in interface ProvisioningEngine

isUseSOCKSProxy

public boolean isUseSOCKSProxy()

Specified by:

isUseSOCKSProxy in interface ProvisioningEngine

getSocksProxyHost

public String getSocksProxyHost()

Specified by:

getSocksProxyHost in interface ProvisioningEngine

getLocalhost

public String getLocalhost()

Specified by:

getLocalhost in interface ProvisioningEngine

getSocksProxyPort

public int getSocksProxyPort()

Specified by:

getSocksProxyPort in interface ProvisioningEngine

clearDLQ

public void clearDLQ()
              throws ProvisioningException

Specified by:

clearDLQ in interface ProvisioningEngine

Throws:

ProvisioningException

dlqMessage

public void dlqMessage(jakarta.jms.TextMessage m)

Specified by:

dlqMessage in interface ProvisioningEngine

endBroker

public void endBroker()

enqueue

public void enqueue(WorkflowHolder wfHolder)
             throws ProvisioningException

Throws:

ProvisioningException

enqueue

public void enqueue(WorkflowHolder wfHolder,
 int num)
             throws ProvisioningException

Throws:

ProvisioningException

execute

public void execute()

returnQueueConnection

public void returnQueueConnection(jakarta.jms.Connection con)

Specified by:

returnQueueConnection in interface ProvisioningEngine

getTaskMessageProducer

public JMSSessionHolder getTaskMessageProducer()
                                        throws Exception

Throws:

Exception

isInternalQueue

public boolean isInternalQueue()

Specified by:

isInternalQueue in interface ProvisioningEngine

initMessageConsumers

public void initMessageConsumers()
                          throws ProvisioningException

Specified by:

initMessageConsumers in interface ProvisioningEngine

Throws:

ProvisioningException

encryptObject

public EncryptedMessage encryptObject(Object o)
                               throws ProvisioningException

Specified by:

encryptObject in interface ProvisioningEngine

Throws:

ProvisioningException

decryptObject

public Object decryptObject(EncryptedMessage msg)
                     throws ProvisioningException

Specified by:

decryptObject in interface ProvisioningEngine

Throws:

ProvisioningException

initScheduler

public void initScheduler()
                   throws ProvisioningException

Specified by:

initScheduler in interface ProvisioningEngine

Throws:

ProvisioningException

deleteRemovedJobs

public void deleteRemovedJobs(HashSet<String> jobKeys,
 String groupName)
                       throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

deleteRemovedLocalJobs

public void deleteRemovedLocalJobs(HashSet<String> jobKeys,
 String groupName)
                            throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

addNewJob

public void addNewJob(HashSet<String> jobKeys,
 JobType jobType)
               throws org.quartz.SchedulerException,
ProvisioningException,
ClassNotFoundException

Specified by:

addNewJob in interface ProvisioningEngine

Throws:

org.quartz.SchedulerException

ProvisioningException

ClassNotFoundException

initListeners

public void initListeners()
                   throws ProvisioningException

Specified by:

initListeners in interface ProvisioningEngine

Throws:

ProvisioningException

addMessageListener

public void addMessageListener(MessageListenerType mlt)
                        throws InstantiationException,
IllegalAccessException,
ClassNotFoundException,
ProvisioningException,
jakarta.jms.JMSException

Specified by:

addMessageListener in interface ProvisioningEngine

Throws:

InstantiationException

IllegalAccessException

ClassNotFoundException

ProvisioningException

jakarta.jms.JMSException

removeMessageListener

public void removeMessageListener(String name)

Specified by:

removeMessageListener in interface ProvisioningEngine

reEnQueueTask

public void reEnQueueTask(jakarta.jms.TextMessage tm,
 int numOfTries)
                   throws Exception

Throws:

Exception

reEnQueue

public void reEnQueue(jakarta.jms.TextMessage tm,
 int numOfTries,
 JMSSessionHolder session)

Specified by:

reEnQueue in interface ProvisioningEngine

getHibernateSessionFactory

public org.hibernate.SessionFactory getHibernateSessionFactory()
                                                        throws ProvisioningException

Specified by:

getHibernateSessionFactory in interface ProvisioningEngine

Throws:

ProvisioningException

rebuildHibernate

public void rebuildHibernate()

Specified by:

rebuildHibernate in interface ProvisioningEngine

deleteJob

public void deleteJob(String jobName,
 String groupName)
               throws org.quartz.SchedulerException

Specified by:

deleteJob in interface ProvisioningEngine

Throws:

org.quartz.SchedulerException