org.apache.activemq.artemis.jms.client

Class ActiveMQConnectionFactory

java.lang.Object

org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, ConnectionFactory, XAConnectionFactory, Referenceable

Direct Known Subclasses:

ActiveMQJMSConnectionFactory, ActiveMQQueueConnectionFactory, ActiveMQTopicConnectionFactory, ActiveMQXAConnectionFactory, ActiveMQXAQueueConnectionFactory, ActiveMQXATopicConnectionFactory

public class ActiveMQConnectionFactory
extends Object
implements Externalizable, Referenceable, ConnectionFactory, XAConnectionFactory, AutoCloseable

ActiveMQ Artemis implementation of a JMS ConnectionFactory.

This connection factory will use defaults defined by DefaultConnectionProperties.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ActiveMQConnectionFactory() This will use a default URI from DefaultConnectionProperties
ActiveMQConnectionFactory(boolean ha, DiscoveryGroupConfiguration groupConfiguration)
ActiveMQConnectionFactory(boolean ha, TransportConfiguration... initialConnectors)
ActiveMQConnectionFactory(ServerLocator serverLocator)
ActiveMQConnectionFactory(String url)
ActiveMQConnectionFactory(String url, String user, String password) For compatibility and users used to this kind of constructor

Method Summary

Modifier and Type	Method and Description
void	close()
Connection	createConnection() Creates a connection with the default user identity.
Connection	createConnection(String username, String password) Creates a connection with the specified user identity.
protected ActiveMQConnection	createConnectionInternal(String username, String password, boolean isXA, int type)
JMSContext	createContext() Creates a JMSContext with the default user identity and an unspecified sessionMode.
JMSContext	createContext(int sessionMode) Creates a JMSContext with the default user identity and the specified session mode.
JMSContext	createContext(String userName, String password) Creates a JMSContext with the specified user identity and an unspecified sessionMode.
JMSContext	createContext(String userName, String password, int sessionMode) Creates a JMSContext with the specified user identity and the specified session mode.
QueueConnection	createQueueConnection()
QueueConnection	createQueueConnection(String username, String password)
TopicConnection	createTopicConnection()
TopicConnection	createTopicConnection(String username, String password)
XAConnection	createXAConnection() Creates an XAConnection with the default user identity.
XAConnection	createXAConnection(String username, String password) Creates an XAConnection with the specified user identity.
XAJMSContext	createXAContext() Creates a XAJMSContext with the default user identity
XAJMSContext	createXAContext(String userName, String password) Creates a JMSContext with the specified user identity
XAQueueConnection	createXAQueueConnection()
XAQueueConnection	createXAQueueConnection(String username, String password)
XATopicConnection	createXATopicConnection()
XATopicConnection	createXATopicConnection(String username, String password)
protected void	finalize()
long	getCallFailoverTimeout()
long	getCallTimeout()
long	getClientFailureCheckPeriod()
String	getClientID()
int	getConfirmationWindowSize()
String	getConnectionLoadBalancingPolicyClassName()
long	getConnectionTTL()
int	getConsumerMaxRate()
int	getConsumerWindowSize()
DiscoveryGroupConfiguration	getDiscoveryGroupConfiguration()
int	getDupsOKBatchSize()
int	getFactoryType()
String	getGroupID()
String	getIncomingInterceptorList()
int	getInitialConnectAttempts()
int	getInitialMessagePacketSize()
long	getMaxRetryInterval()
int	getMinLargeMessageSize()
String	getOutgoingInterceptorList()
String	getPassword()
int	getProducerMaxRate()
int	getProducerWindowSize()
String	getProtocolManagerFactoryStr()
int	getReconnectAttempts()
Reference	getReference()
long	getRetryInterval()
double	getRetryIntervalMultiplier()
int	getScheduledThreadPoolMaxSize()
ServerLocator	getServerLocator()
TransportConfiguration[]	getStaticConnectors()
int	getThreadPoolMaxSize()
int	getTransactionBatchSize()
String	getUser()
boolean	isAutoGroup()
boolean	isBlockOnAcknowledge()
boolean	isBlockOnDurableSend()
boolean	isBlockOnNonDurableSend()
boolean	isCacheLargeMessagesClient()
boolean	isCompressLargeMessage()
boolean	isFailoverOnInitialConnection()
boolean	isHA()
boolean	isPreAcknowledge()
boolean	isUseGlobalPools()
void	readExternal(ObjectInput in)
void	setAutoGroup(boolean autoGroup)
void	setBlockOnAcknowledge(boolean blockOnAcknowledge)
void	setBlockOnDurableSend(boolean blockOnDurableSend)
void	setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
void	setCacheLargeMessagesClient(boolean cacheLargeMessagesClient)
void	setCallFailoverTimeout(long callTimeout)
void	setCallTimeout(long callTimeout)
void	setClientFailureCheckPeriod(long clientFailureCheckPeriod)
void	setClientID(String clientID)
void	setCompressLargeMessage(boolean avoidLargeMessages)
void	setConfirmationWindowSize(int confirmationWindowSize)
void	setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)
void	setConnectionTTL(long connectionTTL)
void	setConsumerMaxRate(int consumerMaxRate)
void	setConsumerWindowSize(int consumerWindowSize)
void	setDupsOKBatchSize(int dupsOKBatchSize)
void	setFailoverOnInitialConnection(boolean failover)
void	setGroupID(String groupID)
void	setIncomingInterceptorList(String interceptorList)
void	setInitialConnectAttempts(int reconnectAttempts)
void	setInitialMessagePacketSize(int size)
void	setMaxRetryInterval(long retryInterval)
void	setMinLargeMessageSize(int minLargeMessageSize)
void	setOutgoingInterceptorList(String interceptorList)
ActiveMQConnectionFactory	setPassword(String password)
void	setPreAcknowledge(boolean preAcknowledge)
void	setProducerMaxRate(int producerMaxRate)
void	setProducerWindowSize(int producerWindowSize)
void	setProtocolManagerFactoryStr(String protocolManagerFactoryStr)
void	setReconnectAttempts(int reconnectAttempts)
void	setRetryInterval(long retryInterval)
void	setRetryIntervalMultiplier(double retryIntervalMultiplier)
void	setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
void	setThreadPoolMaxSize(int threadPoolMaxSize)
void	setTransactionBatchSize(int transactionBatchSize)
void	setUseGlobalPools(boolean useGlobalPools)
ActiveMQConnectionFactory	setUser(String user)
String	toString()
URI	toURI()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ActiveMQConnectionFactory

public ActiveMQConnectionFactory()

This will use a default URI from DefaultConnectionProperties

ActiveMQConnectionFactory

public ActiveMQConnectionFactory(String url)

ActiveMQConnectionFactory

public ActiveMQConnectionFactory(String url,
                                 String user,
                                 String password)

For compatibility and users used to this kind of constructor

ActiveMQConnectionFactory

public ActiveMQConnectionFactory(ServerLocator serverLocator)

ActiveMQConnectionFactory

public ActiveMQConnectionFactory(boolean ha,
                                 DiscoveryGroupConfiguration groupConfiguration)

ActiveMQConnectionFactory

public ActiveMQConnectionFactory(boolean ha,
                                 TransportConfiguration... initialConnectors)

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

toURI

public URI toURI()
          throws IOException

Throws:

IOException

getProtocolManagerFactoryStr

public String getProtocolManagerFactoryStr()

setProtocolManagerFactoryStr

public void setProtocolManagerFactoryStr(String protocolManagerFactoryStr)

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

createConnection

public Connection createConnection()
                            throws JMSException

Description copied from interface: ConnectionFactory

Creates a connection with the default user identity. The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called.

Specified by:

createConnection in interface ConnectionFactory

Returns:

a newly created connection

Throws:

JMSException - if the JMS provider fails to create the connection due to some internal error.

JMSSecurityException - if client authentication fails due to an invalid user name or password.

createConnection

public Connection createConnection(String username,
                                   String password)
                            throws JMSException

Description copied from interface: ConnectionFactory

Creates a connection with the specified user identity. The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called.

Specified by:

createConnection in interface ConnectionFactory

Parameters:

username - the caller's user name

password - the caller's password

Returns:

a newly created connection

Throws:

JMSException - if the JMS provider fails to create the connection due to some internal error.

JMSSecurityException - if client authentication fails due to an invalid user name or password.

createContext

public JMSContext createContext()

Description copied from interface: ConnectionFactory

Creates a JMSContext with the default user identity and an unspecified sessionMode.

A connection and session are created for use by the new JMSContext. The connection is created in stopped mode but will be automatically started when a JMSConsumer is created.

The behaviour of the session that is created depends on whether this method is called in a Java SE environment, in the Java EE application client container, or in the Java EE web or EJB container. If this method is called in the Java EE web or EJB container then the behaviour of the session also depends on whether or not there is an active JTA transaction in progress.

In a Java SE environment or in the Java EE application client container:

• The session will be non-transacted and received messages will be acknowledged automatically using an acknowledgement mode of JMSContext.AUTO_ACKNOWLEDGE For a definition of the meaning of this acknowledgement mode see the link below.

In a Java EE web or EJB container, when there is an active JTA transaction in progress:

• The session will participate in the JTA transaction and will be committed or rolled back when that transaction is committed or rolled back, not by calling the JMSContext's commit or rollback methods.

In the Java EE web or EJB container, when there is no active JTA transaction in progress:

• The session will be non-transacted and received messages will be acknowledged automatically using an acknowledgement mode of JMSContext.AUTO_ACKNOWLEDGE For a definition of the meaning of this acknowledgement mode see the link below.

Specified by:

createContext in interface ConnectionFactory

Returns:

a newly created JMSContext

See Also:

JMSContext.AUTO_ACKNOWLEDGE, ConnectionFactory.createContext(int), ConnectionFactory.createContext(java.lang.String, java.lang.String), ConnectionFactory.createContext(java.lang.String, java.lang.String, int), JMSContext.createContext(int)

createContext

public JMSContext createContext(int sessionMode)

Description copied from interface: ConnectionFactory

Creates a JMSContext with the default user identity and the specified session mode.

A connection and session are created for use by the new JMSContext. The JMSContext is created in stopped mode but will be automatically started when a JMSConsumer is created.

The effect of setting the sessionMode argument depends on whether this method is called in a Java SE environment, in the Java EE application client container, or in the Java EE web or EJB container. If this method is called in the Java EE web or EJB container then the effect of setting the sessionMode argument also depends on whether or not there is an active JTA transaction in progress.

In a Java SE environment or in the Java EE application client container:

• If sessionMode is set to JMSContext.SESSION_TRANSACTED then the session will use a local transaction which may subsequently be committed or rolled back by calling the JMSContext's commit or rollback methods.
• If sessionMode is set to any of JMSContext.CLIENT_ACKNOWLEDGE, JMSContext.AUTO_ACKNOWLEDGE or JMSContext.DUPS_OK_ACKNOWLEDGE. then the session will be non-transacted and messages received by this session will be acknowledged according to the value of sessionMode. For a definition of the meaning of these acknowledgement modes see the links below.

In a Java EE web or EJB container, when there is an active JTA transaction in progress:

• The argument sessionMode is ignored. The session will participate in the JTA transaction and will be committed or rolled back when that transaction is committed or rolled back, not by calling the JMSContext's commit or rollback methods. Since the argument is ignored, developers are recommended to use createSession(), which has no arguments, instead of this method.

In the Java EE web or EJB container, when there is no active JTA transaction in progress:

• The argument acknowledgeMode must be set to either of JMSContext.AUTO_ACKNOWLEDGE or JMSContext.DUPS_OK_ACKNOWLEDGE. The session will be non-transacted and messages received by this session will be acknowledged automatically according to the value of acknowledgeMode. For a definition of the meaning of these acknowledgement modes see the links below. The values JMSContext.SESSION_TRANSACTED and JMSContext.CLIENT_ACKNOWLEDGE may not be used.

Specified by:

createContext in interface ConnectionFactory

Parameters:

sessionMode - indicates which of four possible session modes will be used.

• If this method is called in a Java SE environment or in the Java EE application client container, the permitted values are JMSContext.SESSION_TRANSACTED, JMSContext.CLIENT_ACKNOWLEDGE, JMSContext.AUTO_ACKNOWLEDGE and JMSContext.DUPS_OK_ACKNOWLEDGE.
• If this method is called in the Java EE web or EJB container when there is an active JTA transaction in progress then this argument is ignored.
• If this method is called in the Java EE web or EJB container when there is no active JTA transaction in progress, the permitted values are JMSContext.AUTO_ACKNOWLEDGE and JMSContext.DUPS_OK_ACKNOWLEDGE. In this case the values JMSContext.TRANSACTED and JMSContext.CLIENT_ACKNOWLEDGE are not permitted.

Returns:

a newly created JMSContext

See Also:

JMSContext.SESSION_TRANSACTED, JMSContext.CLIENT_ACKNOWLEDGE, JMSContext.AUTO_ACKNOWLEDGE, JMSContext.DUPS_OK_ACKNOWLEDGE, ConnectionFactory.createContext(), ConnectionFactory.createContext(java.lang.String, java.lang.String), ConnectionFactory.createContext(java.lang.String, java.lang.String, int), JMSContext.createContext(int)

createContext

public JMSContext createContext(String userName,
                                String password)

Description copied from interface: ConnectionFactory

Creates a JMSContext with the specified user identity and an unspecified sessionMode.

A connection and session are created for use by the new JMSContext. The connection is created in stopped mode but will be automatically started when a JMSConsumer.

The behaviour of the session that is created depends on whether this method is called in a Java SE environment, in the Java EE application client container, or in the Java EE web or EJB container. If this method is called in the Java EE web or EJB container then the behaviour of the session also depends on whether or not there is an active JTA transaction in progress.

In a Java SE environment or in the Java EE application client container:

• The session will be non-transacted and received messages will be acknowledged automatically using an acknowledgement mode of JMSContext.AUTO_ACKNOWLEDGE For a definition of the meaning of this acknowledgement mode see the link below.

In a Java EE web or EJB container, when there is an active JTA transaction in progress:

• The session will participate in the JTA transaction and will be committed or rolled back when that transaction is committed or rolled back, not by calling the JMSContext's commit or rollback methods.

In the Java EE web or EJB container, when there is no active JTA transaction in progress:

• The session will be non-transacted and received messages will be acknowledged automatically using an acknowledgement mode of JMSContext.AUTO_ACKNOWLEDGE For a definition of the meaning of this acknowledgement mode see the link below.

Specified by:

createContext in interface ConnectionFactory

Parameters:

userName - the caller's user name

password - the caller's password

Returns:

a newly created JMSContext

See Also:

JMSContext.AUTO_ACKNOWLEDGE, ConnectionFactory.createContext(), ConnectionFactory.createContext(int), ConnectionFactory.createContext(java.lang.String, java.lang.String, int), JMSContext.createContext(int)

createContext

public JMSContext createContext(String userName,
                                String password,
                                int sessionMode)

Description copied from interface: ConnectionFactory

Creates a JMSContext with the specified user identity and the specified session mode.

A connection and session are created for use by the new JMSContext. The JMSContext is created in stopped mode but will be automatically started when a JMSConsumer is created.

The effect of setting the sessionMode argument depends on whether this method is called in a Java SE environment, in the Java EE application client container, or in the Java EE web or EJB container. If this method is called in the Java EE web or EJB container then the effect of setting the sessionMode argument also depends on whether or not there is an active JTA transaction in progress.

In a Java SE environment or in the Java EE application client container:

• If sessionMode is set to JMSContext.SESSION_TRANSACTED then the session will use a local transaction which may subsequently be committed or rolled back by calling the JMSContext's commit or rollback methods.
• If sessionMode is set to any of JMSContext.CLIENT_ACKNOWLEDGE, JMSContext.AUTO_ACKNOWLEDGE or JMSContext.DUPS_OK_ACKNOWLEDGE. then the session will be non-transacted and messages received by this session will be acknowledged according to the value of sessionMode. For a definition of the meaning of these acknowledgement modes see the links below.

In a Java EE web or EJB container, when there is an active JTA transaction in progress:

• The argument sessionMode is ignored. The session will participate in the JTA transaction and will be committed or rolled back when that transaction is committed or rolled back, not by calling the JMSContext's commit or rollback methods. Since the argument is ignored, developers are recommended to use createSession(), which has no arguments, instead of this method.

In the Java EE web or EJB container, when there is no active JTA transaction in progress:

• The argument acknowledgeMode must be set to either of JMSContext.AUTO_ACKNOWLEDGE or JMSContext.DUPS_OK_ACKNOWLEDGE. The session will be non-transacted and messages received by this session will be acknowledged automatically according to the value of acknowledgeMode. For a definition of the meaning of these acknowledgement modes see the links below. The values JMSContext.SESSION_TRANSACTED and JMSContext.CLIENT_ACKNOWLEDGE may not be used.

Specified by:

createContext in interface ConnectionFactory

Parameters:

userName - the caller's user name

password - the caller's password

sessionMode - indicates which of four possible session modes will be used.

• If this method is called in a Java SE environment or in the Java EE application client container, the permitted values are JMSContext.SESSION_TRANSACTED, JMSContext.CLIENT_ACKNOWLEDGE, JMSContext.AUTO_ACKNOWLEDGE and JMSContext.DUPS_OK_ACKNOWLEDGE.
• If this method is called in the Java EE web or EJB container when there is an active JTA transaction in progress then this argument is ignored.
• If this method is called in the Java EE web or EJB container when there is no active JTA transaction in progress, the permitted values are JMSContext.AUTO_ACKNOWLEDGE and JMSContext.DUPS_OK_ACKNOWLEDGE. In this case the values JMSContext.TRANSACTED and JMSContext.CLIENT_ACKNOWLEDGE are not permitted.

Returns:

a newly created JMSContext

See Also:

JMSContext.SESSION_TRANSACTED, JMSContext.CLIENT_ACKNOWLEDGE, JMSContext.AUTO_ACKNOWLEDGE, JMSContext.DUPS_OK_ACKNOWLEDGE, ConnectionFactory.createContext(), ConnectionFactory.createContext(int), ConnectionFactory.createContext(java.lang.String, java.lang.String), JMSContext.createContext(int)

createQueueConnection

public QueueConnection createQueueConnection()
                                      throws JMSException

Throws:

JMSException

createQueueConnection

public QueueConnection createQueueConnection(String username,
                                             String password)
                                      throws JMSException

Throws:

JMSException

createTopicConnection

public TopicConnection createTopicConnection()
                                      throws JMSException

Throws:

JMSException

createTopicConnection

public TopicConnection createTopicConnection(String username,
                                             String password)
                                      throws JMSException

Throws:

JMSException

createXAConnection

public XAConnection createXAConnection()
                                throws JMSException

Description copied from interface: XAConnectionFactory

Creates an XAConnection with the default user identity. The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called.

Specified by:

createXAConnection in interface XAConnectionFactory

Returns:

a newly created XAConnection

Throws:

JMSException - if the JMS provider fails to create an XA connection due to some internal error.

JMSSecurityException - if client authentication fails due to an invalid user name or password.

createXAConnection

public XAConnection createXAConnection(String username,
                                       String password)
                                throws JMSException

Description copied from interface: XAConnectionFactory

Creates an XAConnection with the specified user identity. The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called.

Specified by:

createXAConnection in interface XAConnectionFactory

Parameters:

username - the caller's user name

password - the caller's password

Returns:

a newly created XAConnection

Throws:

JMSException - if the JMS provider fails to create an XA connection due to some internal error.

JMSSecurityException - if client authentication fails due to an invalid user name or password.

createXAContext

public XAJMSContext createXAContext()

Description copied from interface: XAConnectionFactory

Creates a XAJMSContext with the default user identity

A connection and session are created for use by the new XAJMSContext. The connection is created in stopped mode but will be automatically started when a JMSConsumer is created.

Specified by:

createXAContext in interface XAConnectionFactory

Returns:

a newly created XAJMSContext

createXAContext

public XAJMSContext createXAContext(String userName,
                                    String password)

Description copied from interface: XAConnectionFactory

Creates a JMSContext with the specified user identity

A connection and session are created for use by the new XAJMSContext. The connection is created in stopped mode but will be automatically started when a JMSConsumer is created.

Specified by:

createXAContext in interface XAConnectionFactory

Parameters:

userName - the caller's user name

password - the caller's password

Returns:

a newly created JMSContext

createXAQueueConnection

public XAQueueConnection createXAQueueConnection()
                                          throws JMSException

Throws:

JMSException

createXAQueueConnection

public XAQueueConnection createXAQueueConnection(String username,
                                                 String password)
                                          throws JMSException

Throws:

JMSException

createXATopicConnection

public XATopicConnection createXATopicConnection()
                                          throws JMSException

Throws:

JMSException

createXATopicConnection

public XATopicConnection createXATopicConnection(String username,
                                                 String password)
                                          throws JMSException

Throws:

JMSException

getReference

public Reference getReference()
                       throws NamingException

Specified by:

getReference in interface Referenceable

Throws:

NamingException

isHA

public boolean isHA()

getConnectionLoadBalancingPolicyClassName

public String getConnectionLoadBalancingPolicyClassName()

setConnectionLoadBalancingPolicyClassName

public void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)

getStaticConnectors

public TransportConfiguration[] getStaticConnectors()

getDiscoveryGroupConfiguration

public DiscoveryGroupConfiguration getDiscoveryGroupConfiguration()

getClientID

public String getClientID()

setClientID

public void setClientID(String clientID)

getDupsOKBatchSize

public int getDupsOKBatchSize()

setDupsOKBatchSize

public void setDupsOKBatchSize(int dupsOKBatchSize)

getTransactionBatchSize

public int getTransactionBatchSize()

setTransactionBatchSize

public void setTransactionBatchSize(int transactionBatchSize)

getClientFailureCheckPeriod

public long getClientFailureCheckPeriod()

setClientFailureCheckPeriod

public void setClientFailureCheckPeriod(long clientFailureCheckPeriod)

getConnectionTTL

public long getConnectionTTL()

setConnectionTTL

public void setConnectionTTL(long connectionTTL)

getCallTimeout

public long getCallTimeout()

setCallTimeout

public void setCallTimeout(long callTimeout)

getCallFailoverTimeout

public long getCallFailoverTimeout()

setCallFailoverTimeout

public void setCallFailoverTimeout(long callTimeout)

getConsumerWindowSize

public int getConsumerWindowSize()

setConsumerWindowSize

public void setConsumerWindowSize(int consumerWindowSize)

getConsumerMaxRate

public int getConsumerMaxRate()

setConsumerMaxRate

public void setConsumerMaxRate(int consumerMaxRate)

getConfirmationWindowSize

public int getConfirmationWindowSize()

setConfirmationWindowSize

public void setConfirmationWindowSize(int confirmationWindowSize)

getProducerMaxRate

public int getProducerMaxRate()

setProducerMaxRate

public void setProducerMaxRate(int producerMaxRate)

getProducerWindowSize

public int getProducerWindowSize()

setProducerWindowSize

public void setProducerWindowSize(int producerWindowSize)

setCacheLargeMessagesClient

public void setCacheLargeMessagesClient(boolean cacheLargeMessagesClient)

Parameters:

cacheLargeMessagesClient -

isCacheLargeMessagesClient

public boolean isCacheLargeMessagesClient()

getMinLargeMessageSize

public int getMinLargeMessageSize()

setMinLargeMessageSize

public void setMinLargeMessageSize(int minLargeMessageSize)

isBlockOnAcknowledge

public boolean isBlockOnAcknowledge()

setBlockOnAcknowledge

public void setBlockOnAcknowledge(boolean blockOnAcknowledge)

isBlockOnNonDurableSend

public boolean isBlockOnNonDurableSend()

setBlockOnNonDurableSend

public void setBlockOnNonDurableSend(boolean blockOnNonDurableSend)

isBlockOnDurableSend

public boolean isBlockOnDurableSend()

setBlockOnDurableSend

public void setBlockOnDurableSend(boolean blockOnDurableSend)

isAutoGroup

public boolean isAutoGroup()

setAutoGroup

public void setAutoGroup(boolean autoGroup)

isPreAcknowledge

public boolean isPreAcknowledge()

setPreAcknowledge

public void setPreAcknowledge(boolean preAcknowledge)

getRetryInterval

public long getRetryInterval()

setRetryInterval

public void setRetryInterval(long retryInterval)

getMaxRetryInterval

public long getMaxRetryInterval()

setMaxRetryInterval

public void setMaxRetryInterval(long retryInterval)

getRetryIntervalMultiplier

public double getRetryIntervalMultiplier()

setRetryIntervalMultiplier

public void setRetryIntervalMultiplier(double retryIntervalMultiplier)

getReconnectAttempts

public int getReconnectAttempts()

setReconnectAttempts

public void setReconnectAttempts(int reconnectAttempts)

setInitialConnectAttempts

public void setInitialConnectAttempts(int reconnectAttempts)

getInitialConnectAttempts

public int getInitialConnectAttempts()

isFailoverOnInitialConnection

public boolean isFailoverOnInitialConnection()

setFailoverOnInitialConnection

public void setFailoverOnInitialConnection(boolean failover)

isUseGlobalPools

public boolean isUseGlobalPools()

setUseGlobalPools

public void setUseGlobalPools(boolean useGlobalPools)

getScheduledThreadPoolMaxSize

public int getScheduledThreadPoolMaxSize()

setScheduledThreadPoolMaxSize

public void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)

getThreadPoolMaxSize

public int getThreadPoolMaxSize()

setThreadPoolMaxSize

public void setThreadPoolMaxSize(int threadPoolMaxSize)

getInitialMessagePacketSize

public int getInitialMessagePacketSize()

setInitialMessagePacketSize

public void setInitialMessagePacketSize(int size)

setIncomingInterceptorList

public void setIncomingInterceptorList(String interceptorList)

Parameters:

interceptorList - a comma separated string of incoming interceptor class names to be used. Each interceptor needs a default Constructor to be used with this method.

getIncomingInterceptorList

public String getIncomingInterceptorList()

setOutgoingInterceptorList

public void setOutgoingInterceptorList(String interceptorList)

Parameters:

interceptorList - a comma separated string of incoming interceptor class names to be used. Each interceptor needs a default Constructor to be used with this method.

getOutgoingInterceptorList

public String getOutgoingInterceptorList()

setUser

public ActiveMQConnectionFactory setUser(String user)

getUser

public String getUser()

getPassword

public String getPassword()

setPassword

public ActiveMQConnectionFactory setPassword(String password)

setGroupID

public void setGroupID(String groupID)

getGroupID

public String getGroupID()

isCompressLargeMessage

public boolean isCompressLargeMessage()

setCompressLargeMessage

public void setCompressLargeMessage(boolean avoidLargeMessages)

close

public void close()

Specified by:

close in interface AutoCloseable

getServerLocator

public ServerLocator getServerLocator()

getFactoryType

public int getFactoryType()

createConnectionInternal

protected ActiveMQConnection createConnectionInternal(String username,
                                                      String password,
                                                      boolean isXA,
                                                      int type)
                                               throws JMSException

Throws:

JMSException

toString

public String toString()

Overrides:

toString in class Object

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable