public class MuleMQJmsConnector extends JmsConnector
JMS, password, REDELIVERY_FAIL_ON_FIRST, REDELIVERY_IGNORE, username
connecting, createMultipleTransactedReceivers, DEFAULT_CONTEXT_START_TIMEOUT, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, MULE_CONTEXT_START_TIMEOUT_SYSTEM_PROPERTY, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
MuleMQJmsConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
protected void |
doInitialise() |
int |
getAutoAckCount() |
String |
getBufferOutput() |
protected ConnectionFactory |
getDefaultConnectionFactory()
Override this method to provide a default ConnectionFactory for a vendor-specific JMS Connector.
|
int |
getGlobalStoreCapacity() |
int |
getInitialRetryCount() |
int |
getMaxUnackedSize() |
int |
getMessageThreadPoolSize() |
protected String |
getMuleMQFactoryClass() |
int |
getMuleMqMaxRedelivery() |
int |
getQueueWindowSize() |
String |
getRealmURL() |
int |
getSyncBatchSize() |
int |
getSyncTime() |
boolean |
isDiscOnClusterFailure() |
boolean |
isEnableMultiplexedConnections() |
boolean |
isEnableSharedDurable() |
boolean |
isInCluster() |
boolean |
isRandomiseRNames() |
boolean |
isRetryCommit() |
boolean |
isSupportJms102bSpec() |
boolean |
isSyncWrites() |
boolean |
isUseJMSEngine() |
void |
onException(JMSException jmsException) |
void |
setAutoAckCount(int autoAckCount) |
void |
setBufferOutput(String bufferOutput) |
void |
setDiscOnClusterFailure(boolean discOnClusterFailure) |
void |
setEnableMultiplexedConnections(boolean enableMultiplexedConnections) |
void |
setEnableSharedDurable(boolean enableSharedDurable) |
void |
setGlobalStoreCapacity(int globalStoreCapacity) |
void |
setInCluster(boolean inCluster) |
void |
setInitialRetryCount(int initialRetryCount) |
void |
setMaxUnackedSize(int maxUnackedSize) |
void |
setMessageThreadPoolSize(int messageThreadPoolSize) |
void |
setMuleMqMaxRedelivery(int mulqMqMaxRedelivery) |
void |
setQueueWindowSize(int queueWindowSize) |
void |
setRandomiseRNames(boolean randomiseRNames) |
void |
setRealmURL(String realmURL) |
void |
setRetryCommit(boolean retryCommit) |
void |
setSpecification(String specification) |
void |
setSupportJms102bSpec(boolean supportJms102bSpec) |
void |
setSyncBatchSize(int syncBatchSize) |
void |
setSyncTime(int syncTime) |
void |
setSyncWrites(boolean syncWrites) |
void |
setUseJMSEngine(boolean useJMSEngine) |
close, close, close, close, close, closeQuietly, closeQuietly, closeQuietly, closeQuietly, closeQuietly, closeSessionIfNoTransactionActive, connect, createConnection, createConnectionFactory, createJmsSupport, createOperationResource, createSession, doConnect, doDisconnect, doDispose, doStart, doStop, getAcknowledgementMode, getClientId, getConnection, getConnectionFactory, getConnectionFactoryJndiName, getConnectionFactoryProperties, getJmsSupport, getJndiInitialFactory, getJndiNameResolver, getJndiProviderProperties, getJndiProviderUrl, getMaxRedelivery, getNumberOfConsumers, getOperationResourceFactory, getPassword, getProtocol, getReceiverKey, getRedeliveryHandlerFactory, getReplyToHandler, getSameRMOverrideValue, getSelector, getSession, getSession, getSessionFromTransaction, getSpecification, getTopicResolver, getUsername, isCacheJmsSessions, isDisableTemporaryReplyToDestinations, isDurable, isEagerConsumer, isEmbeddedMode, isForceJndiDestinations, isHonorQosHeaders, isJndiDestinations, isNoLocal, isPersistentDelivery, isResponseEnabled, isReturnOriginalMessageAsReply, lookupFromJndi, preProcessMessage, scheduleTimeoutTask, setAcknowledgementMode, setCacheJmsSessions, setClientId, setConnection, setConnectionFactory, setConnectionFactoryJndiName, setConnectionFactoryProperties, setDisableTemporaryReplyToDestinations, setDurable, setEagerConsumer, setEmbeddedMode, setForceJndiDestinations, setHonorQosHeaders, setJmsSupport, setJndiDestinations, setJndiInitialFactory, setJndiNameResolver, setJndiProviderProperties, setJndiProviderUrl, setMaxRedelivery, setNoLocal, setNumberOfConsumers, setPassword, setPersistentDelivery, setRedeliveryHandlerFactory, setReturnOriginalMessageAsReply, setSameRMOverrideValue, setTopicResolver, setUsername, supportsProperty
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connectConnectorAndReceivers, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, fireNotification, getCanonicalURI, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isEnableMessageEvents, isInitialised, isInitialStateStopped, 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
getAnnotation, getAnnotations, setAnnotations
public static final String MULEMQ_CONNECTION_FACTORY_CLASS
public static final String DEFAULT_REALM_URL
public static final String DEFAULT_BUFFER_OUTPUT
public static final boolean DEFAULT_SYNC_WRITES
public static final int DEFAULT_SYNC_BATCH_SIZE
public static final int DEFAULT_SYNC_TIME
public static final int DEFAULT_GLOBAL_STORE_CAPACITY
public static final int DEFAULT_MAX_UNACKED_SIZE
public static final boolean DEFAULT_USE_JMS_ENGINE
public static final int DEFAULT_QUEUE_WINDOW_SIZE
public static final int DEFAULT_AUTO_ACK_COUNT
public static final boolean DEFAULT_ENABLE_SHARED_DURABLE
public static final boolean DEFAULT_RANDOMISE_R_NAMES
public static final int DEFAULT_MAX_REDELIVERY
public static final int DEFAULT_MESSAGE_THREAD_POOL_SIZE
public static final boolean DEFAULT_DISC_ON_CLUSTER_FAILURE
public static final int DEFAULT_INITIAL_RETRY_COUNT
public static final boolean DEFAULT_RETRY_COMMIT
public static final boolean DEFAULT_ENABLE_MULTIPLEXED_CONNECTIONS
protected static final String BUFFER_OUTPUT
protected static final String SYNC_WRITES
protected static final String SYNC_BATCH_SIZE
protected static final String SYNC_TIME
protected static final String GLOBAL_STORE_CAPACITY
protected static final String MAX_UNACKED_SIZE
protected static final String USE_JMS_ENGINE
protected static final String QUEUE_WINDOW_SIZE
protected static final String AUTO_ACK_COUNT
protected static final String ENABLE_SHARED_DURABLE
protected static final String RANDOMISE_R_NAMES
protected static final String MAX_REDELIVERY
protected static final String MESSAGE_THREAD_POOL_SIZE
protected static final String DISC_ON_CLUSTER_FAILURE
protected static final String INITIAL_RETRY_COUNT
protected static final String RETRY_COMMIT
protected static final String ENABLE_MULTIPLEXED_CONNECTIONS
public boolean supportJms102bSpec
public MuleMQJmsConnector(MuleContext context)
public boolean isSupportJms102bSpec()
public void setSupportJms102bSpec(boolean supportJms102bSpec)
public void setSpecification(String specification)
setSpecification
in class JmsConnector
protected void doInitialise() throws InitialisationException
doInitialise
in class JmsConnector
InitialisationException
protected ConnectionFactory getDefaultConnectionFactory() throws Exception
JmsConnector
getDefaultConnectionFactory
in class JmsConnector
Exception
protected String getMuleMQFactoryClass()
public String getRealmURL()
public void setRealmURL(String realmURL)
public String getBufferOutput()
public void setBufferOutput(String bufferOutput)
public boolean isSyncWrites()
public void setSyncWrites(boolean syncWrites)
public int getSyncBatchSize()
public void setSyncBatchSize(int syncBatchSize)
public int getSyncTime()
public void setSyncTime(int syncTime)
public int getGlobalStoreCapacity()
public void setGlobalStoreCapacity(int globalStoreCapacity)
public int getMaxUnackedSize()
public void setMaxUnackedSize(int maxUnackedSize)
public boolean isUseJMSEngine()
public void setUseJMSEngine(boolean useJMSEngine)
public int getQueueWindowSize()
public void setQueueWindowSize(int queueWindowSize)
public int getAutoAckCount()
public void setAutoAckCount(int autoAckCount)
public boolean isEnableSharedDurable()
public void setEnableSharedDurable(boolean enableSharedDurable)
public boolean isRandomiseRNames()
public void setRandomiseRNames(boolean randomiseRNames)
public int getMessageThreadPoolSize()
public void setMessageThreadPoolSize(int messageThreadPoolSize)
public boolean isDiscOnClusterFailure()
public void setDiscOnClusterFailure(boolean discOnClusterFailure)
public int getInitialRetryCount()
public void setInitialRetryCount(int initialRetryCount)
public int getMuleMqMaxRedelivery()
public void setMuleMqMaxRedelivery(int mulqMqMaxRedelivery)
public void setRetryCommit(boolean retryCommit)
public boolean isRetryCommit()
public boolean isEnableMultiplexedConnections()
public void setEnableMultiplexedConnections(boolean enableMultiplexedConnections)
public boolean isInCluster()
public void setInCluster(boolean inCluster)
public void onException(JMSException jmsException)
onException
in interface ExceptionListener
onException
in class JmsConnector
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.