| |
|
| java.lang.Object org.mule.transport.AbstractConnector org.mule.transport.quartz.QuartzConnector
QuartzConnector | public class QuartzConnector extends AbstractConnector (Code) | | Creates a connection to a Quartz sheduler. This allows events to be sheduled at
specific times, with repeated occurences.
|
DEFAULT_GROUP_NAME | final public static String DEFAULT_GROUP_NAME(Code) | | |
PROPERTY_CRON_EXPRESSION | final public static String PROPERTY_CRON_EXPRESSION(Code) | | |
PROPERTY_GROUP_NAME | final public static String PROPERTY_GROUP_NAME(Code) | | |
PROPERTY_JOB_CLASS | final public static String PROPERTY_JOB_CLASS(Code) | | |
PROPERTY_JOB_DISPATCH_ENDPOINT | final public static String PROPERTY_JOB_DISPATCH_ENDPOINT(Code) | | |
PROPERTY_JOB_GROUP_NAME | final public static String PROPERTY_JOB_GROUP_NAME(Code) | | |
PROPERTY_JOB_OBJECT | final public static String PROPERTY_JOB_OBJECT(Code) | | |
PROPERTY_JOB_RECEIVE_ENDPOINT | final public static String PROPERTY_JOB_RECEIVE_ENDPOINT(Code) | | |
PROPERTY_JOB_RECEIVE_TIMEOUT | final public static String PROPERTY_JOB_RECEIVE_TIMEOUT(Code) | | |
PROPERTY_JOB_REF | final public static String PROPERTY_JOB_REF(Code) | | |
PROPERTY_PAYLOAD | final public static String PROPERTY_PAYLOAD(Code) | | |
PROPERTY_PAYLOAD_CLASS_NAME | final public static String PROPERTY_PAYLOAD_CLASS_NAME(Code) | | deprecated: use PROPERTY_PAYLOAD_REFERENCE
|
PROPERTY_PAYLOAD_REFERENCE | final public static String PROPERTY_PAYLOAD_REFERENCE(Code) | | |
PROPERTY_REPEAT_COUNT | final public static String PROPERTY_REPEAT_COUNT(Code) | | |
PROPERTY_REPEAT_INTERVAL | final public static String PROPERTY_REPEAT_INTERVAL(Code) | | |
PROPERTY_START_DELAY | final public static String PROPERTY_START_DELAY(Code) | | |
doDispose | protected void doDispose()(Code) | | |
getQuartzScheduler | public Scheduler getQuartzScheduler()(Code) | | |
setFactoryProperties | public void setFactoryProperties(Properties factoryProperties)(Code) | | |
setQuartzScheduler | public void setQuartzScheduler(Scheduler scheduler)(Code) | | |
Methods inherited from org.mule.transport.AbstractConnector | protected void checkDisposed() throws DisposeException(Code)(Java Doc) public void connect() throws Exception(Code)(Java Doc) protected MessageReceiver createReceiver(Service service, InboundEndpoint endpoint) throws Exception(Code)(Java Doc) public void destroyReceiver(MessageReceiver receiver, InboundEndpoint endpoint) throws Exception(Code)(Java Doc) public void disconnect() throws Exception(Code)(Java Doc) public void dispatch(OutboundEndpoint endpoint, MuleEvent event) throws DispatchException(Code)(Java Doc) final public synchronized void dispose()(Code)(Java Doc) protected void disposeDispatchers()(Code)(Java Doc) protected void disposeReceivers()(Code)(Java Doc) protected void disposeRequesters()(Code)(Java Doc) protected void disposeWorkManagers()(Code)(Java Doc) abstract protected void doConnect() throws Exception(Code)(Java Doc) abstract protected void doDisconnect() throws Exception(Code)(Java Doc) abstract protected void doDispose()(Code)(Java Doc) abstract protected void doInitialise() throws InitialisationException(Code)(Java Doc) abstract protected void doStart() throws MuleException(Code)(Java Doc) abstract protected void doStop() throws MuleException(Code)(Java Doc) public void exceptionThrown(Exception e)(Code)(Java Doc) public void fireNotification(ServerNotification notification)(Code)(Java Doc) protected String getConnectEventId()(Code)(Java Doc) public String getConnectionDescription()(Code)(Java Doc) public ConnectionStrategy getConnectionStrategy()(Code)(Java Doc) public List getDefaultInboundTransformers()(Code)(Java Doc) public List getDefaultOutboundTransformers()(Code)(Java Doc) public List getDefaultResponseTransformers()(Code)(Java Doc) public MessageDispatcherFactory getDispatcherFactory()(Code)(Java Doc) public ThreadingProfile getDispatcherThreadingProfile()(Code)(Java Doc) protected WorkManager getDispatcherWorkManager() throws MuleException(Code)(Java Doc) public ExceptionListener getExceptionListener()(Code)(Java Doc) public int getMaxDispatchersActive()(Code)(Java Doc) public int getMaxRequestersActive()(Code)(Java Doc) public MessageAdapter getMessageAdapter(Object message) throws MessagingException(Code)(Java Doc) public MuleContext getMuleContext()(Code)(Java Doc) public String getName()(Code)(Java Doc) public int getNumberOfConcurrentTransactedReceivers()(Code)(Java Doc) public OutputStream getOutputStream(OutboundEndpoint endpoint, MuleMessage message) throws MuleException(Code)(Java Doc) public MessageReceiver getReceiver(Service service, InboundEndpoint endpoint)(Code)(Java Doc) protected Object getReceiverKey(Service service, InboundEndpoint endpoint)(Code)(Java Doc) public ThreadingProfile getReceiverThreadingProfile()(Code)(Java Doc) protected WorkManager getReceiverWorkManager(String receiverName) throws MuleException(Code)(Java Doc) public Map getReceivers()(Code)(Java Doc) public MessageReceiver[] getReceivers(String wildcardExpression)(Code)(Java Doc) public ReplyToHandler getReplyToHandler()(Code)(Java Doc) public MessageRequesterFactory getRequesterFactory()(Code)(Java Doc) public ThreadingProfile getRequesterThreadingProfile()(Code)(Java Doc) protected WorkManager getRequesterWorkManager() throws MuleException(Code)(Java Doc) public ScheduledExecutorService getScheduler()(Code)(Java Doc) protected TransportServiceDescriptor getServiceDescriptor()(Code)(Java Doc) public Map getServiceOverrides()(Code)(Java Doc) public SessionHandler getSessionHandler()(Code)(Java Doc) public List getSupportedProtocols()(Code)(Java Doc) public void handleException(Exception exception)(Code)(Java Doc) protected void handleWorkException(WorkEvent event, String type)(Code)(Java Doc) protected synchronized void initFromServiceDescriptor() throws InitialisationException(Code)(Java Doc) protected void initWorkManagers() throws MuleException(Code)(Java Doc) final public synchronized LifecycleTransitionResult initialise() throws InitialisationException(Code)(Java Doc) public void initialiseFromUrl(EndpointURI endpointUri) throws InitialisationException(Code)(Java Doc) final public boolean isConnected()(Code)(Java Doc) public boolean isCreateMultipleTransactedReceivers()(Code)(Java Doc) public boolean isDisposed()(Code)(Java Doc) public boolean isDisposing()(Code)(Java Doc) public boolean isEnableMessageEvents()(Code)(Java Doc) public boolean isRemoteSyncEnabled()(Code)(Java Doc) public boolean isStarted()(Code)(Java Doc) public boolean isSyncEnabled(String protocol)(Code)(Java Doc) public MessageReceiver lookupReceiver(String key)(Code)(Java Doc) public MessageReceiver registerListener(Service service, InboundEndpoint endpoint) throws Exception(Code)(Java Doc) public void registerSupportedProtocol(String protocol)(Code)(Java Doc) protected void registerSupportedProtocolWithoutPrefix(String protocol)(Code)(Java Doc) public MuleMessage request(String uri, long timeout) throws Exception(Code)(Java Doc) public MuleMessage request(InboundEndpoint endpoint, long timeout) throws Exception(Code)(Java Doc) public MuleMessage send(OutboundEndpoint endpoint, MuleEvent event) throws DispatchException(Code)(Java Doc) public void setConnectionStrategy(ConnectionStrategy connectionStrategy)(Code)(Java Doc) public void setCreateMultipleTransactedReceivers(boolean createMultipleTransactedReceivers)(Code)(Java Doc) public void setDispatcherFactory(MessageDispatcherFactory dispatcherFactory)(Code)(Java Doc) public void setDispatcherThreadingProfile(ThreadingProfile dispatcherThreadingProfile)(Code)(Java Doc) public void setDynamicNotification(boolean dynamic)(Code)(Java Doc) public void setExceptionListener(ExceptionListener listener)(Code)(Java Doc) public void setMaxDispatchersActive(int maxActive)(Code)(Java Doc) public void setMaxRequestersActive(int maxActive)(Code)(Java Doc) public void setMuleContext(MuleContext context)(Code)(Java Doc) public void setName(String newName)(Code)(Java Doc) public void setNumberOfConcurrentTransactedReceivers(int count)(Code)(Java Doc) public void setReceiverThreadingProfile(ThreadingProfile receiverThreadingProfile)(Code)(Java Doc) public void setRequesterFactory(MessageRequesterFactory requesterFactory)(Code)(Java Doc) public void setRequesterThreadingProfile(ThreadingProfile requesterThreadingProfile)(Code)(Java Doc) public void setServiceOverrides(Map serviceOverrides)(Code)(Java Doc) public void setSessionHandler(SessionHandler sessionHandler)(Code)(Java Doc) public void setSupportedProtocols(List supportedProtocols)(Code)(Java Doc) protected void setupDispatchReturn(OutboundEndpoint endpoint, MessageDispatcher dispatcher, MuleMessage result)(Code)(Java Doc) protected void setupRequestReturn(InboundEndpoint endpoint, MessageRequester requester, MuleMessage result)(Code)(Java Doc) final public synchronized LifecycleTransitionResult start() throws MuleException(Code)(Java Doc) final public synchronized LifecycleTransitionResult stop() throws MuleException(Code)(Java Doc) public boolean supportsProtocol(String protocol)(Code)(Java Doc) public String toString()(Code)(Java Doc) final public void unregisterListener(Service service, InboundEndpoint endpoint) throws Exception(Code)(Java Doc) public void unregisterSupportedProtocol(String protocol)(Code)(Java Doc) protected void updateCachedNotificationHandler()(Code)(Java Doc) public void workAccepted(WorkEvent event)(Code)(Java Doc) public void workCompleted(WorkEvent event)(Code)(Java Doc) public void workRejected(WorkEvent event)(Code)(Java Doc) public void workStarted(WorkEvent event)(Code)(Java Doc)
|
|
|
|