public abstract class AbstractMailConnector extends AbstractConnector
Modifier and Type | Field and Description |
---|---|
static String |
ATTACHMENT_HEADERS_PROPERTY_POSTFIX |
static String |
MAILBOX |
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 |
---|
AbstractMailConnector(int defaultPort,
String mailboxFolder,
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
|
protected void |
dumpProperties(String title,
Properties properties,
boolean filter) |
protected void |
extendPropertiesForSession(Properties global,
Properties local,
URLName url)
Subclasses should extend this to add further properties.
|
Authenticator |
getAuthenticator() |
protected String |
getBaseProtocol()
Some protocols (eg secure extensions) extend a "base" protocol.
|
int |
getDefaultPort() |
String |
getMailboxFolder() |
SessionDetails |
getSessionDetails(ImmutableEndpoint endpoint) |
protected SessionDetails |
newSession(ImmutableEndpoint endpoint) |
void |
setAuthenticator(Authenticator authenticator) |
void |
setMailboxFolder(String mailboxFolder) |
URLName |
urlFromEndpoint(ImmutableEndpoint endpoint) |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getProtocol
public static final String ATTACHMENT_HEADERS_PROPERTY_POSTFIX
public static final String MAILBOX
public AbstractMailConnector(int defaultPort, String mailboxFolder, MuleContext context)
public int getDefaultPort()
public Authenticator getAuthenticator()
public void setAuthenticator(Authenticator authenticator)
public String getMailboxFolder()
public void setMailboxFolder(String mailboxFolder)
public SessionDetails getSessionDetails(ImmutableEndpoint endpoint) throws UnsupportedEncodingException
UnsupportedEncodingException
public URLName urlFromEndpoint(ImmutableEndpoint endpoint) throws UnsupportedEncodingException
UnsupportedEncodingException
protected String getBaseProtocol()
protected void extendPropertiesForSession(Properties global, Properties local, URLName url)
global
- system propertieslocal
- local properties (specific to one session)url
- the endpoint urlprotected SessionDetails newSession(ImmutableEndpoint endpoint) throws UnsupportedEncodingException
UnsupportedEncodingException
protected void dumpProperties(String title, Properties properties, boolean filter)
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 failsCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.