org.mule.transport.jms.mulemq
Class MuleMQJmsConnector
java.lang.Object
org.mule.transport.AbstractConnector
org.mule.transport.jms.JmsConnector
org.mule.transport.jms.mulemq.MuleMQJmsConnector
- All Implemented Interfaces:
- EventListener, ExceptionListener, javax.resource.spi.work.WorkListener, Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, NameableObject, NamedObject, Connectable, Connector
- Direct Known Subclasses:
- MuleMQXAJmsConnector
public class MuleMQJmsConnector
- extends JmsConnector
Fields inherited from class org.mule.transport.AbstractConnector |
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 |
Methods inherited from class org.mule.transport.jms.JmsConnector |
close, close, close, close, close, closeQuietly, closeQuietly, closeQuietly, closeQuietly, closeQuietly, closeSessionIfNoTransactionActive, 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, 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 |
Methods inherited from class org.mule.transport.AbstractConnector |
clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, 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, isInitialised, isInitialStateStopped, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, 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 |
MULEMQ_CONNECTION_FACTORY_CLASS
public static final String MULEMQ_CONNECTION_FACTORY_CLASS
- See Also:
- Constant Field Values
DEFAULT_REALM_URL
public static final String DEFAULT_REALM_URL
- See Also:
- Constant Field Values
DEFAULT_BUFFER_OUTPUT
public static final String DEFAULT_BUFFER_OUTPUT
- See Also:
- Constant Field Values
DEFAULT_SYNC_WRITES
public static final boolean DEFAULT_SYNC_WRITES
- See Also:
- Constant Field Values
DEFAULT_SYNC_BATCH_SIZE
public static final int DEFAULT_SYNC_BATCH_SIZE
- See Also:
- Constant Field Values
DEFAULT_SYNC_TIME
public static final int DEFAULT_SYNC_TIME
- See Also:
- Constant Field Values
DEFAULT_GLOBAL_STORE_CAPACITY
public static final int DEFAULT_GLOBAL_STORE_CAPACITY
- See Also:
- Constant Field Values
DEFAULT_MAX_UNACKED_SIZE
public static final int DEFAULT_MAX_UNACKED_SIZE
- See Also:
- Constant Field Values
DEFAULT_USE_JMS_ENGINE
public static final boolean DEFAULT_USE_JMS_ENGINE
- See Also:
- Constant Field Values
DEFAULT_QUEUE_WINDOW_SIZE
public static final int DEFAULT_QUEUE_WINDOW_SIZE
- See Also:
- Constant Field Values
DEFAULT_AUTO_ACK_COUNT
public static final int DEFAULT_AUTO_ACK_COUNT
- See Also:
- Constant Field Values
DEFAULT_ENABLE_SHARED_DURABLE
public static final boolean DEFAULT_ENABLE_SHARED_DURABLE
- See Also:
- Constant Field Values
DEFAULT_RANDOMISE_R_NAMES
public static final boolean DEFAULT_RANDOMISE_R_NAMES
- See Also:
- Constant Field Values
DEFAULT_MAX_REDELIVERY
public static final int DEFAULT_MAX_REDELIVERY
- See Also:
- Constant Field Values
DEFAULT_MESSAGE_THREAD_POOL_SIZE
public static final int DEFAULT_MESSAGE_THREAD_POOL_SIZE
- See Also:
- Constant Field Values
DEFAULT_DISC_ON_CLUSTER_FAILURE
public static final boolean DEFAULT_DISC_ON_CLUSTER_FAILURE
- See Also:
- Constant Field Values
DEFAULT_INITIAL_RETRY_COUNT
public static final int DEFAULT_INITIAL_RETRY_COUNT
- See Also:
- Constant Field Values
DEFAULT_RETRY_COMMIT
public static final boolean DEFAULT_RETRY_COMMIT
- See Also:
- Constant Field Values
DEFAULT_ENABLE_MULTIPLEXED_CONNECTIONS
public static final boolean DEFAULT_ENABLE_MULTIPLEXED_CONNECTIONS
- See Also:
- Constant Field Values
BUFFER_OUTPUT
protected static final String BUFFER_OUTPUT
- See Also:
- Constant Field Values
SYNC_WRITES
protected static final String SYNC_WRITES
- See Also:
- Constant Field Values
SYNC_BATCH_SIZE
protected static final String SYNC_BATCH_SIZE
- See Also:
- Constant Field Values
SYNC_TIME
protected static final String SYNC_TIME
- See Also:
- Constant Field Values
GLOBAL_STORE_CAPACITY
protected static final String GLOBAL_STORE_CAPACITY
- See Also:
- Constant Field Values
MAX_UNACKED_SIZE
protected static final String MAX_UNACKED_SIZE
- See Also:
- Constant Field Values
USE_JMS_ENGINE
protected static final String USE_JMS_ENGINE
- See Also:
- Constant Field Values
QUEUE_WINDOW_SIZE
protected static final String QUEUE_WINDOW_SIZE
- See Also:
- Constant Field Values
AUTO_ACK_COUNT
protected static final String AUTO_ACK_COUNT
- See Also:
- Constant Field Values
ENABLE_SHARED_DURABLE
protected static final String ENABLE_SHARED_DURABLE
- See Also:
- Constant Field Values
RANDOMISE_R_NAMES
protected static final String RANDOMISE_R_NAMES
- See Also:
- Constant Field Values
MAX_REDELIVERY
protected static final String MAX_REDELIVERY
- See Also:
- Constant Field Values
MESSAGE_THREAD_POOL_SIZE
protected static final String MESSAGE_THREAD_POOL_SIZE
- See Also:
- Constant Field Values
DISC_ON_CLUSTER_FAILURE
protected static final String DISC_ON_CLUSTER_FAILURE
- See Also:
- Constant Field Values
INITIAL_RETRY_COUNT
protected static final String INITIAL_RETRY_COUNT
- See Also:
- Constant Field Values
RETRY_COMMIT
protected static final String RETRY_COMMIT
- See Also:
- Constant Field Values
ENABLE_MULTIPLEXED_CONNECTIONS
protected static final String ENABLE_MULTIPLEXED_CONNECTIONS
- See Also:
- Constant Field Values
supportJms102bSpec
public boolean supportJms102bSpec
MuleMQJmsConnector
public MuleMQJmsConnector(MuleContext context)
isSupportJms102bSpec
public boolean isSupportJms102bSpec()
setSupportJms102bSpec
public void setSupportJms102bSpec(boolean supportJms102bSpec)
setSpecification
public void setSpecification(String specification)
- Overrides:
setSpecification
in class JmsConnector
doInitialise
protected void doInitialise()
throws InitialisationException
- Overrides:
doInitialise
in class JmsConnector
- Throws:
InitialisationException
getDefaultConnectionFactory
protected ConnectionFactory getDefaultConnectionFactory()
throws Exception
- Description copied from class:
JmsConnector
- Override this method to provide a default ConnectionFactory for a vendor-specific JMS Connector.
- Overrides:
getDefaultConnectionFactory
in class JmsConnector
- Throws:
Exception
getMuleMQFactoryClass
protected String getMuleMQFactoryClass()
getRealmURL
public String getRealmURL()
setRealmURL
public void setRealmURL(String realmURL)
getBufferOutput
public String getBufferOutput()
setBufferOutput
public void setBufferOutput(String bufferOutput)
isSyncWrites
public boolean isSyncWrites()
setSyncWrites
public void setSyncWrites(boolean syncWrites)
getSyncBatchSize
public int getSyncBatchSize()
setSyncBatchSize
public void setSyncBatchSize(int syncBatchSize)
getSyncTime
public int getSyncTime()
setSyncTime
public void setSyncTime(int syncTime)
getGlobalStoreCapacity
public int getGlobalStoreCapacity()
setGlobalStoreCapacity
public void setGlobalStoreCapacity(int globalStoreCapacity)
getMaxUnackedSize
public int getMaxUnackedSize()
setMaxUnackedSize
public void setMaxUnackedSize(int maxUnackedSize)
isUseJMSEngine
public boolean isUseJMSEngine()
setUseJMSEngine
public void setUseJMSEngine(boolean useJMSEngine)
getQueueWindowSize
public int getQueueWindowSize()
setQueueWindowSize
public void setQueueWindowSize(int queueWindowSize)
getAutoAckCount
public int getAutoAckCount()
setAutoAckCount
public void setAutoAckCount(int autoAckCount)
isEnableSharedDurable
public boolean isEnableSharedDurable()
setEnableSharedDurable
public void setEnableSharedDurable(boolean enableSharedDurable)
isRandomiseRNames
public boolean isRandomiseRNames()
setRandomiseRNames
public void setRandomiseRNames(boolean randomiseRNames)
getMessageThreadPoolSize
public int getMessageThreadPoolSize()
setMessageThreadPoolSize
public void setMessageThreadPoolSize(int messageThreadPoolSize)
isDiscOnClusterFailure
public boolean isDiscOnClusterFailure()
setDiscOnClusterFailure
public void setDiscOnClusterFailure(boolean discOnClusterFailure)
getInitialRetryCount
public int getInitialRetryCount()
setInitialRetryCount
public void setInitialRetryCount(int initialRetryCount)
getMuleMqMaxRedelivery
public int getMuleMqMaxRedelivery()
setMuleMqMaxRedelivery
public void setMuleMqMaxRedelivery(int mulqMqMaxRedelivery)
setRetryCommit
public void setRetryCommit(boolean retryCommit)
isRetryCommit
public boolean isRetryCommit()
isEnableMultiplexedConnections
public boolean isEnableMultiplexedConnections()
setEnableMultiplexedConnections
public void setEnableMultiplexedConnections(boolean enableMultiplexedConnections)
isInCluster
public boolean isInCluster()
setInCluster
public void setInCluster(boolean inCluster)
onException
public void onException(JMSException jmsException)
- Specified by:
onException
in interface ExceptionListener
- Overrides:
onException
in class JmsConnector
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.