org.jboss.soa.esb.services.jbpm.integration.timer
Class JmsSchedulerService

java.lang.Object
  org.jboss.soa.esb.services.jbpm.integration.AbstractJmsJobService
      org.jboss.soa.esb.services.jbpm.integration.timer.JmsSchedulerService

All Implemented Interfaces:

java.io.Serializable, org.jbpm.scheduler.SchedulerService, org.jbpm.svc.Service

public class JmsSchedulerService
extends AbstractJmsJobService
implements org.jbpm.scheduler.SchedulerService

Implementation of the jBPM scheduler service targeting quartz.

Author:

Kevin Conner

See Also:

Serialized Form

Field Summary

Fields inherited from class org.jboss.soa.esb.services.jbpm.integration.AbstractJmsJobService

log

Constructor Summary

JmsSchedulerService(org.jbpm.JbpmContext jbpmContext, javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination, boolean isCommitEnabled, JmsScheduledDeliveryStrategy scheduledDeliveryStrategy)
Create the JMS scheduler service.

Method Summary

void	createTimer(org.jbpm.job.Timer timer) Create a timer.
void	deleteTimer(org.jbpm.job.Timer timer) Delete a specific timer.
void	deleteTimersByName(java.lang.String timerName, org.jbpm.graph.exe.Token token) Delete a specific timer given a name and associated jBPM token.
void	deleteTimersByProcessInstance(org.jbpm.graph.exe.ProcessInstance processInstance) Delete timers associated with a jBPM process instance.

Methods inherited from class org.jboss.soa.esb.services.jbpm.integration.AbstractJmsJobService

close, getJobSession, getMessageProducer, getSession, send

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jbpm.svc.Service

close

Constructor Detail

JmsSchedulerService

public JmsSchedulerService(org.jbpm.JbpmContext jbpmContext,
                           javax.jms.ConnectionFactory connectionFactory,
                           javax.jms.Destination destination,
                           boolean isCommitEnabled,
                           JmsScheduledDeliveryStrategy scheduledDeliveryStrategy)
                    throws javax.jms.JMSException

Create the JMS scheduler service.

Parameters:

jbpmContext - The current jBPM context.

connectionFactory - The associated JMS connection factory.

destination - The JMS destination for jobs.

isCommitEnabled - true if commit should be invoked, false otherwise.

Throws:

javax.jms.JMSException - For errors in constructing the JMS session.

Method Detail

createTimer

public void createTimer(org.jbpm.job.Timer timer)

Create a timer.

Specified by:

createTimer in interface org.jbpm.scheduler.SchedulerService

Parameters:

timer - the timer to create.

deleteTimer

public void deleteTimer(org.jbpm.job.Timer timer)

Delete a specific timer.

Specified by:

deleteTimer in interface org.jbpm.scheduler.SchedulerService

Parameters:

timer - The timer to delete.

deleteTimersByName

public void deleteTimersByName(java.lang.String timerName,
                               org.jbpm.graph.exe.Token token)

Delete a specific timer given a name and associated jBPM token.

Specified by:

deleteTimersByName in interface org.jbpm.scheduler.SchedulerService

Parameters:

timerName - The name of the timer to delete.

token - The token associated with the timer.

deleteTimersByProcessInstance

public void deleteTimersByProcessInstance(org.jbpm.graph.exe.ProcessInstance processInstance)

Delete timers associated with a jBPM process instance.

Specified by:

deleteTimersByProcessInstance in interface org.jbpm.scheduler.SchedulerService

Parameters:

processInstance - The process instance associated with the timers.