public class AjaxServletConnector extends ServletConnector implements BayeuxAware
Modifier and Type | Field and Description |
---|---|
protected org.mortbay.cometd.AbstractBayeux |
bayeux |
static String |
PROTOCOL |
CHARACTER_ENCODING_PROPERTY_KEY, CONTENT_TYPE_PROPERTY_KEY, PARAMETER_MAP_PROPERTY_KEY, PARAMETER_PROPERTY_PREFIX, SERVLET, servletUrl, SESSION_ID_PROPERTY_KEY
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 |
---|
AjaxServletConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
protected MessageReceiver |
createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
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'.
|
int |
getTimeout() |
boolean |
isJsonCommented() |
boolean |
isRequestAvailable() |
void |
setBayeux(org.mortbay.cometd.AbstractBayeux bayeux) |
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 |
setTimeout(int timeout) |
doConnect, doDisconnect, doDispose, doInitialise, doStart, doStop, getReceiverKey, getReceivers, getServletUrl, isUseCachedHttpServletRequest, setServletUrl, setUseCachedHttpServletRequest
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, 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
protected org.mortbay.cometd.AbstractBayeux bayeux
public AjaxServletConnector(MuleContext context)
public org.mortbay.cometd.AbstractBayeux getBayeux()
getBayeux
in interface BayeuxAware
public void setBayeux(org.mortbay.cometd.AbstractBayeux bayeux) throws MuleException
setBayeux
in interface BayeuxAware
MuleException
public String getProtocol()
getProtocol
in interface Connector
getProtocol
in class ServletConnector
public 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 int getRefsThreshold()
public void setRefsThreshold(int refsThreshold)
public ReplyToHandler getReplyToHandler(ImmutableEndpoint endpoint)
AbstractConnector
getReplyToHandler
in class AbstractConnector
protected MessageReceiver createReceiver(FlowConstruct flowConstruct, InboundEndpoint endpoint) throws Exception
AbstractConnector
createReceiver
in class AbstractConnector
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 thrownCopyright © 2003–2015 MuleSoft, Inc.. All rights reserved.