public class QuartzConnector extends AbstractConnector
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_GROUP_NAME |
static String |
PROPERTY_CRON_EXPRESSION |
static String |
PROPERTY_JOB_CONFIG |
static String |
PROPERTY_JOB_DATA |
static String |
PROPERTY_JOB_DYNAMIC |
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 |
static String |
QUARTZ_INSTANCE_NAME_PROPERTY |
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
Constructor and Description |
---|
QuartzConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
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
|
Properties |
getFactoryProperties() |
String |
getProtocol() |
org.quartz.Scheduler |
getQuartzScheduler() |
void |
setFactoryProperties(Properties factoryProperties) |
void |
setQuartzScheduler(org.quartz.Scheduler scheduler) |
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getCanonicalURI, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOperationResourceFactory, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, returnDispatcher, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
public static final String QUARTZ
public static final String PROPERTY_CRON_EXPRESSION
public static final String PROPERTY_REPEAT_INTERVAL
public static final String PROPERTY_REPEAT_COUNT
public static final String PROPERTY_START_DELAY
public static final String PROPERTY_PAYLOAD
public static final String PROPERTY_JOB_CONFIG
public static final String PROPERTY_JOB_DATA
public static final String PROPERTY_JOB_REF
public static final String PROPERTY_JOB_OBJECT
public static final String PROPERTY_JOB_DYNAMIC
public static final String DEFAULT_GROUP_NAME
public static final String QUARTZ_INSTANCE_NAME_PROPERTY
public QuartzConnector(MuleContext context)
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractConnector
InitialisationException
protected void doDispose()
AbstractConnector
doDispose
in class AbstractConnector
protected void doConnect() throws Exception
AbstractConnector
doConnect
in class AbstractConnector
Exception
protected void doDisconnect() throws Exception
AbstractConnector
doDisconnect
in class AbstractConnector
Exception
protected void doStart() throws MuleException
AbstractConnector
doStart
in class AbstractConnector
MuleException
- if the method failsprotected void doStop() throws MuleException
AbstractConnector
doStop
in class AbstractConnector
MuleException
- if the method failspublic String getProtocol()
public org.quartz.Scheduler getQuartzScheduler()
public void setQuartzScheduler(org.quartz.Scheduler scheduler)
public Properties getFactoryProperties()
public void setFactoryProperties(Properties factoryProperties)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.