public class AjaxConnector extends JettyHttpsConnector implements BayeuxAware
mule.jsclass to publish and subscribe events. Note that a resource base property can be set on the ajax endpoint that provides the location of any web application resources such as html pages.
JettyHttpConnector.MuleReceiverConnectorHolder
Modifier and Type | Field and Description |
---|---|
static String |
AJAX_PATH_SPEC |
static String |
CHANNEL_PROPERTY |
static String |
COMETD_CLIENT |
static String |
PROTOCOL |
static String |
REPLYTO_PARAM
This is the key that's used to retrieve the reply to destination from a
Map that's
passed into AjaxMuleMessageFactory . |
HTTPS, JETTY_SSL, LOCAL_CERTIFICATES, PEER_CERTIFICATES
holders, JETTY, MULE_CONTEXT_ATTRIBUTE, ROOT
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 |
---|
AjaxConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
boolean |
canHostFullWars()
A helper method to differentiate between jetty-based connectors which can host full wars and ones which can't.
|
protected org.eclipse.jetty.server.AbstractNetworkConnector |
createJettyConnector() |
protected MessageReceiver |
createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
Servlet |
createServlet(org.eclipse.jetty.server.AbstractNetworkConnector connector,
ImmutableEndpoint endpoint) |
protected void |
doInitialise() |
protected void |
doStart()
Template method to perform any work when starting the connectoe
|
org.mortbay.cometd.AbstractBayeux |
getBayeux() |
String |
getFilters() |
int |
getInterval() |
int |
getLogLevel() |
int |
getMaxInterval() |
int |
getMultiFrameInterval() |
String |
getProtocol() |
int |
getRefsThreshold() |
ReplyToHandler |
getReplyToHandler(ImmutableEndpoint endpoint)
Getter for property 'replyToHandler'.
|
URL |
getServerUrl() |
int |
getTimeout() |
boolean |
isDirectDeliver() |
boolean |
isDisableReplyTo() |
boolean |
isJsonCommented() |
boolean |
isRequestAvailable() |
protected void |
populateContext(org.eclipse.jetty.servlet.ServletContextHandler context) |
void |
setBayeux(org.mortbay.cometd.AbstractBayeux bayeux) |
void |
setDirectDeliver(boolean directDeliver) |
void |
setDisableReplyTo(boolean disableReplyTo) |
void |
setFilters(String filters) |
void |
setInterval(int interval) |
void |
setJsonCommented(boolean jsonCommented) |
void |
setLogLevel(int logLevel) |
void |
setMaxInterval(int maxInterval) |
void |
setMultiFrameInterval(int multiFrameInterval) |
void |
setRefsThreshold(int refsThreshold) |
void |
setRequestAvailable(boolean requestAvailable) |
void |
setServerUrl(URL serverUrl) |
void |
setTimeout(int timeout) |
protected void |
validateSslConfig() |
getClientKeyStore, getClientKeyStorePassword, getClientKeyStoreType, getKeyAlias, getKeyManagerAlgorithm, getKeyManagerFactory, getKeyPassword, getKeyStore, getKeyStorePassword, getKeyStoreType, getSslType, getTrustManagerAlgorithm, getTrustManagerFactory, getTrustStore, getTrustStorePassword, getTrustStoreType, isExplicitTrustStoreOnly, isRequireClientAuthentication, setClientKeyStore, setClientKeyStorePassword, setClientKeyStoreType, setExplicitTrustStoreOnly, setKeyAlias, setKeyManagerAlgorithm, setKeyPassword, setKeyStore, setKeyStorePassword, setKeyStoreType, setRequireClientAuthentication, setSslType, setTrustManagerAlgorithm, setTrustManagerFactory, setTrustStore, setTrustStorePassword, setTrustStoreType
addHandler, configureConnector, createContextHolder, doConnect, doDisconnect, doDispose, doStop, getAcceptors, getConfigFile, getHolderKey, getHttpServer, getReceiverServlet, getResourceBase, getSelectors, getVirtualHostName, getWebappsConfiguration, initialiseFromConfigFile, isUseContinuations, setAcceptors, setConfigFile, setReceiverServlet, setResourceBase, setSelectors, setupJettyLogging, setUseContinuations, setWebappsConfiguration, unregisterListener
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, 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, 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 PROTOCOL
public static final String CHANNEL_PROPERTY
public static final String AJAX_PATH_SPEC
public static final String COMETD_CLIENT
public static final String REPLYTO_PARAM
Map
that's
passed into AjaxMuleMessageFactory
.public AjaxConnector(MuleContext context)
public String getProtocol()
getProtocol
in interface Connector
getProtocol
in class JettyHttpsConnector
public URL getServerUrl()
public void setServerUrl(URL serverUrl)
protected void doInitialise() throws InitialisationException
doInitialise
in class JettyHttpsConnector
InitialisationException
protected void doStart() throws MuleException
AbstractConnector
doStart
in class JettyHttpConnector
MuleException
- if the method failsprotected void validateSslConfig() throws InitialisationException
validateSslConfig
in class JettyHttpsConnector
InitialisationException
public ReplyToHandler getReplyToHandler(ImmutableEndpoint endpoint)
AbstractConnector
getReplyToHandler
in class AbstractConnector
public Servlet createServlet(org.eclipse.jetty.server.AbstractNetworkConnector connector, ImmutableEndpoint endpoint)
createServlet
in class JettyHttpConnector
protected void populateContext(org.eclipse.jetty.servlet.ServletContextHandler context)
protected org.eclipse.jetty.server.AbstractNetworkConnector createJettyConnector()
createJettyConnector
in class JettyHttpsConnector
public org.mortbay.cometd.AbstractBayeux getBayeux()
getBayeux
in interface BayeuxAware
public void setBayeux(org.mortbay.cometd.AbstractBayeux bayeux)
setBayeux
in interface BayeuxAware
protected MessageReceiver createReceiver(FlowConstruct flowConstruct, InboundEndpoint endpoint) throws Exception
AbstractConnector
createReceiver
in class JettyHttpConnector
flowConstruct
- the service that will receive events from this receiver, the
listenerendpoint
- the endpoint that defies this inbound communicationTransportServiceDescriptor
initialised using the service and endpoint.Exception
- if there is a problem creating the receiver. This exception
really depends on the underlying transport, thus any exception
could be thrownpublic int getInterval()
public void setInterval(int interval)
public int getMaxInterval()
public void setMaxInterval(int maxInterval)
public int getMultiFrameInterval()
public void setMultiFrameInterval(int multiFrameInterval)
public int getLogLevel()
public void setLogLevel(int logLevel)
public int getTimeout()
public void setTimeout(int timeout)
public boolean isJsonCommented()
public void setJsonCommented(boolean jsonCommented)
public String getFilters()
public void setFilters(String filters)
public boolean isRequestAvailable()
public void setRequestAvailable(boolean requestAvailable)
public boolean isDirectDeliver()
public void setDirectDeliver(boolean directDeliver)
public int getRefsThreshold()
public void setRefsThreshold(int refsThreshold)
public boolean canHostFullWars()
JettyHttpConnector
canHostFullWars
in class JettyHttpConnector
public void setDisableReplyTo(boolean disableReplyTo)
public boolean isDisableReplyTo()
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.