org.mule.providers.quartz
Class QuartzConnector

java.lang.Object
  org.mule.providers.AbstractConnector
      org.mule.providers.quartz.QuartzConnector

All Implemented Interfaces:

Disposable, EventListener, ExceptionListener, Initialisable, UMOConnectable, UMOConnector, WorkListener

public class QuartzConnector

extends AbstractConnector

Creates a connection to a Quartz sheduler. This allows events to be sheduled at specific times, with repeated occurences.

Field Summary

static String	DEFAULT_GROUP_NAME
static String	PROPERTY_CRON_EXPRESSION
static String	PROPERTY_GROUP_NAME
static String	PROPERTY_JOB_CLASS
static String	PROPERTY_JOB_DISPATCH_ENDPOINT
static String	PROPERTY_JOB_GROUP_NAME
static String	PROPERTY_JOB_OBJECT
static String	PROPERTY_JOB_RECEIVE_ENDPOINT
static String	PROPERTY_JOB_RECEIVE_TIMEOUT
static String	PROPERTY_JOB_REF
static String	PROPERTY_PAYLOAD
static String	PROPERTY_PAYLOAD_CLASS_NAME deprecated: use PROPERTY_PAYLOAD_REFERENCE
static String	PROPERTY_PAYLOAD_REFERENCE
static String	PROPERTY_REPEAT_COUNT
static String	PROPERTY_REPEAT_INTERVAL
static String	PROPERTY_START_DELAY

Fields inherited from class org.mule.providers.AbstractConnector

connected, connecting, connectionStrategy, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, numberOfConcurrentTransactedReceivers, receivers, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect

Fields inherited from interface org.mule.umo.provider.UMOConnector

INT_VALUE_NOT_SET

Constructor Summary

QuartzConnector()

Method Summary

protected void	doConnect() Template method where any connections should be made for the connector
protected void	doDisconnect() Template method where any connected resources used by the connector should be disconnected
protected void	doDispose() Template method to perform any work when destroying the connectoe
protected void	doInitialise()
protected void	doStart() Template method to perform any work when starting the connectoe
protected void	doStop() Template method to perform any work when stopping the connectoe
org.quartz.SchedulerFactory	getFactory()
String	getFactoryClassName()
Properties	getFactoryProperties()
String	getProtocol()
org.quartz.Scheduler	getQuartzScheduler()
void	setFactory(org.quartz.SchedulerFactory factory)
void	setFactoryClassName(String factoryClassName)
void	setFactoryProperties(Properties factoryProperties)
void	setQuartzScheduler(org.quartz.Scheduler scheduler)

Methods inherited from class org.mule.providers.AbstractConnector

checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeWorkManagers, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMessageAdapter, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getStreamMessageAdapter, getSupportedProtocols, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isStarted, lookupReceiver, receive, receive, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, send, setConnectionStrategy, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setMaxDispatchersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setServiceOverrides, setSessionHandler, setSupportedProtocols, startConnector, stopConnector, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_CRON_EXPRESSION

public static final String PROPERTY_CRON_EXPRESSION

See Also:

Constant Field Values

PROPERTY_REPEAT_INTERVAL

public static final String PROPERTY_REPEAT_INTERVAL

See Also:

Constant Field Values

PROPERTY_REPEAT_COUNT

public static final String PROPERTY_REPEAT_COUNT

See Also:

Constant Field Values

PROPERTY_START_DELAY

public static final String PROPERTY_START_DELAY

See Also:

Constant Field Values

PROPERTY_PAYLOAD

public static final String PROPERTY_PAYLOAD

See Also:

Constant Field Values

PROPERTY_JOB_DISPATCH_ENDPOINT

public static final String PROPERTY_JOB_DISPATCH_ENDPOINT

See Also:

Constant Field Values

PROPERTY_JOB_RECEIVE_ENDPOINT

public static final String PROPERTY_JOB_RECEIVE_ENDPOINT

See Also:

Constant Field Values

PROPERTY_JOB_RECEIVE_TIMEOUT

public static final String PROPERTY_JOB_RECEIVE_TIMEOUT

See Also:

Constant Field Values

PROPERTY_PAYLOAD_CLASS_NAME

public static final String PROPERTY_PAYLOAD_CLASS_NAME

deprecated: use PROPERTY_PAYLOAD_REFERENCE

See Also:

Constant Field Values

PROPERTY_PAYLOAD_REFERENCE

public static final String PROPERTY_PAYLOAD_REFERENCE

See Also:

Constant Field Values

PROPERTY_GROUP_NAME

public static final String PROPERTY_GROUP_NAME

See Also:

Constant Field Values

PROPERTY_JOB_GROUP_NAME

public static final String PROPERTY_JOB_GROUP_NAME

See Also:

Constant Field Values

PROPERTY_JOB_REF

public static final String PROPERTY_JOB_REF

See Also:

Constant Field Values

PROPERTY_JOB_CLASS

public static final String PROPERTY_JOB_CLASS

See Also:

Constant Field Values

PROPERTY_JOB_OBJECT

public static final String PROPERTY_JOB_OBJECT

See Also:

Constant Field Values

DEFAULT_GROUP_NAME

public static final String DEFAULT_GROUP_NAME

See Also:

Constant Field Values

Constructor Detail

QuartzConnector

public QuartzConnector()

Method Detail

doInitialise

protected void doInitialise()
                     throws InitialisationException

Specified by:

doInitialise in class AbstractConnector

Throws:

InitialisationException

doDispose

protected void doDispose()

Description copied from class: AbstractConnector

Template method to perform any work when destroying the connectoe

Specified by:

doDispose in class AbstractConnector

doConnect

protected void doConnect()
                  throws Exception

Description copied from class: AbstractConnector

Template method where any connections should be made for the connector

Specified by:

doConnect in class AbstractConnector

Throws:

Exception

doDisconnect

protected void doDisconnect()
                     throws Exception

Description copied from class: AbstractConnector

Template method where any connected resources used by the connector should be disconnected

Specified by:

doDisconnect in class AbstractConnector

Throws:

Exception

doStart

protected void doStart()
                throws UMOException

Description copied from class: AbstractConnector

Template method to perform any work when starting the connectoe

Specified by:

doStart in class AbstractConnector

Throws:

UMOException - if the method fails

doStop

protected void doStop()
               throws UMOException

Description copied from class: AbstractConnector

Template method to perform any work when stopping the connectoe

Specified by:

doStop in class AbstractConnector

Throws:

UMOException - if the method fails

getProtocol

public String getProtocol()

Returns:

the primary protocol name for endpoints of this connector

getFactory

public org.quartz.SchedulerFactory getFactory()

setFactory

public void setFactory(org.quartz.SchedulerFactory factory)

getQuartzScheduler

public org.quartz.Scheduler getQuartzScheduler()

setQuartzScheduler

public void setQuartzScheduler(org.quartz.Scheduler scheduler)

getFactoryClassName

public String getFactoryClassName()

setFactoryClassName

public void setFactoryClassName(String factoryClassName)

getFactoryProperties

public Properties getFactoryProperties()

setFactoryProperties

public void setFactoryProperties(Properties factoryProperties)