org.mule.transport.quartz
Class QuartzConnector

java.lang.Object
  extended by org.mule.transport.AbstractConnector
      extended by org.mule.transport.quartz.QuartzConnector
All Implemented Interfaces:
ExceptionListener, EventListener, javax.resource.spi.work.WorkListener, MuleContextAware, Disposable, Initialisable, Lifecycle, Startable, Stoppable, NamedObject, Connectable, Connector

public class QuartzConnector
extends AbstractConnector

Creates a connection to a Quartz scheduler. This allows events to be scheduled at specific times, with repeated occurrences.


Field Summary
static String DEFAULT_GROUP_NAME
           
static String PROPERTY_CRON_EXPRESSION
           
static String PROPERTY_JOB_CONFIG
           
static String PROPERTY_JOB_OBJECT
           
static String PROPERTY_JOB_REF
           
static String PROPERTY_PAYLOAD
           
static String PROPERTY_REPEAT_COUNT
           
static String PROPERTY_REPEAT_INTERVAL
           
static String PROPERTY_START_DELAY
           
static String QUARTZ
           
 
Fields inherited from class org.mule.transport.AbstractConnector
connected, createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatchers, disposed, exceptionListener, initialised, logger, muleContext, name, numberOfConcurrentTransactedReceivers, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, started, startOnConnect
 
Fields inherited from interface org.mule.api.transport.Connector
INT_VALUE_NOT_SET
 
Fields inherited from interface org.mule.api.lifecycle.Initialisable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Startable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Stoppable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Disposable
PHASE_NAME
 
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
 MuleClient getClient()
          A shared MuleClient for EndpointPollingJobs.
 Properties getFactoryProperties()
           
 String getProtocol()
           
 org.quartz.Scheduler getQuartzScheduler()
           
 void setFactoryProperties(Properties factoryProperties)
           
 void setQuartzScheduler(org.quartz.Scheduler scheduler)
           
 
Methods inherited from class org.mule.transport.AbstractConnector
checkDisposed, connect, createReceiver, destroyReceiver, disconnect, dispatch, dispose, disposeDispatchers, disposeReceivers, disposeRequesters, disposeWorkManagers, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getExceptionListener, getMaxDispatchersActive, getMaxRequestersActive, getMessageAdapter, getMuleContext, getName, getNumberOfConcurrentTransactedReceivers, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, handleException, handleException, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isResponseEnabled, isStarted, isSyncEnabled, isValidateConnections, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, send, setConnected, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherThreadingProfile, setDynamicNotification, setExceptionListener, setMaxDispatchersActive, setMaxRequestersActive, setMuleContext, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, start, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

QUARTZ

public static final String QUARTZ
See Also:
Constant Field Values

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_CONFIG

public static final String PROPERTY_JOB_CONFIG
See Also:
Constant Field Values

PROPERTY_JOB_REF

public static final String PROPERTY_JOB_REF
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 MuleException
Description copied from class: AbstractConnector
Template method to perform any work when starting the connectoe

Specified by:
doStart in class AbstractConnector
Throws:
MuleException - if the method fails

doStop

protected void doStop()
               throws MuleException
Description copied from class: AbstractConnector
Template method to perform any work when stopping the connectoe

Specified by:
doStop in class AbstractConnector
Throws:
MuleException - if the method fails

getProtocol

public String getProtocol()
Returns:
the primary protocol name for endpoints of this connector

getQuartzScheduler

public org.quartz.Scheduler getQuartzScheduler()

setQuartzScheduler

public void setQuartzScheduler(org.quartz.Scheduler scheduler)

getFactoryProperties

public Properties getFactoryProperties()

setFactoryProperties

public void setFactoryProperties(Properties factoryProperties)

getClient

public MuleClient getClient()
                     throws MuleException
A shared MuleClient for EndpointPollingJobs.

Returns:
Throws:
MuleException


Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.