HornetQConnectionFactory (JBoss Application Server: Build 7.1.2.Final API)

java.lang.Object
- org.hornetq.jms.client.HornetQConnectionFactory

All Implemented Interfaces:

Serializable, Referenceable

Direct Known Subclasses:

HornetQJMSConnectionFactory, HornetQQueueConnectionFactory, HornetQTopicConnectionFactory, HornetQXAConnectionFactory, HornetQXAQueueConnectionFactory, HornetQXATopicConnectionFactory
```
public class HornetQConnectionFactory
extends Object
implements Serializable, Referenceable
```
HornetQ implementation of a JMS ConnectionFactory.

Version:

$Revision$ $Id$

Author:

Ovidiu Feodorov, Tim Fox

See Also:
Serialized Form

Constructor Summary

Constructors
Constructor and Description
`HornetQConnectionFactory()`
`HornetQConnectionFactory(boolean ha, DiscoveryGroupConfiguration groupConfiguration)`
`HornetQConnectionFactory(boolean ha, TransportConfiguration... initialConnectors)`
`HornetQConnectionFactory(ServerLocator serverLocator)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`close()`
`Connection`	`createConnection()`
`Connection`	`createConnection(String username, String password)`
`protected HornetQConnection`	`createConnectionInternal(String username, String password, boolean isXA, int type)`
`QueueConnection`	`createQueueConnection()`
`QueueConnection`	`createQueueConnection(String username, String password)`
`TopicConnection`	`createTopicConnection()`
`TopicConnection`	`createTopicConnection(String username, String password)`
`XAConnection`	`createXAConnection()`
`XAConnection`	`createXAConnection(String username, String password)`
`XAQueueConnection`	`createXAQueueConnection()`
`XAQueueConnection`	`createXAQueueConnection(String username, String password)`
`XATopicConnection`	`createXATopicConnection()`
`XATopicConnection`	`createXATopicConnection(String username, String password)`
`void`	`finalize()`
`long`	`getCallTimeout()`
`long`	`getClientFailureCheckPeriod()`
`String`	`getClientID()`
`int`	`getConfirmationWindowSize()`
`String`	`getConnectionLoadBalancingPolicyClassName()`
`long`	`getConnectionTTL()`
`int`	`getConsumerMaxRate()`
`int`	`getConsumerWindowSize()`
`ClientSessionFactory`	`getCoreFactory()` Deprecated. use `ServerLocator.createSessionFactory()`
`DiscoveryGroupConfiguration`	`getDiscoveryGroupConfiguration()`
`int`	`getDupsOKBatchSize()`
`int`	`getFactoryType()`
`String`	`getGroupID()`
`int`	`getInitialConnectAttempts()`
`int`	`getInitialMessagePacketSize()`
`long`	`getMaxRetryInterval()`
`int`	`getMinLargeMessageSize()`
`int`	`getProducerMaxRate()`
`int`	`getProducerWindowSize()`
`int`	`getReconnectAttempts()`
`Reference`	`getReference()`
`long`	`getRetryInterval()`
`double`	`getRetryIntervalMultiplier()`
`int`	`getScheduledThreadPoolMaxSize()`
`ServerLocator`	`getServerLocator()`
`TransportConfiguration[]`	`getStaticConnectors()`
`int`	`getThreadPoolMaxSize()`
`int`	`getTransactionBatchSize()`
`boolean`	`isAutoGroup()`
`boolean`	`isBlockOnAcknowledge()`
`boolean`	`isBlockOnDurableSend()`
`boolean`	`isBlockOnNonDurableSend()`
`boolean`	`isCacheLargeMessagesClient()`
`boolean`	`isCompressLargeMessage()`
`boolean`	`isFailoverOnInitialConnection()`
`boolean`	`isHA()`
`boolean`	`isPreAcknowledge()`
`boolean`	`isUseGlobalPools()`
`void`	`setAutoGroup(boolean autoGroup)`
`void`	`setBlockOnAcknowledge(boolean blockOnAcknowledge)`
`void`	`setBlockOnDurableSend(boolean blockOnDurableSend)`
`void`	`setBlockOnNonDurableSend(boolean blockOnNonDurableSend)`
`void`	`setCacheLargeMessagesClient(boolean cacheLargeMessagesClient)`
`void`	`setCallTimeout(long callTimeout)`
`void`	`setClientFailureCheckPeriod(long clientFailureCheckPeriod)`
`void`	`setClientID(String clientID)`
`void`	`setCompressLargeMessage(boolean compress)`
`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`	`setInitialConnectAttempts(int reconnectAttempts)`
`void`	`setInitialMessagePacketSize(int size)`
`void`	`setMaxRetryInterval(long retryInterval)`
`void`	`setMinLargeMessageSize(int minLargeMessageSize)`
`void`	`setPreAcknowledge(boolean preAcknowledge)`
`void`	`setProducerMaxRate(int producerMaxRate)`
`void`	`setProducerWindowSize(int producerWindowSize)`
`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)`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HornetQConnectionFactory
```
public HornetQConnectionFactory()
```

HornetQConnectionFactory

public HornetQConnectionFactory(ServerLocator serverLocator)

HornetQConnectionFactory

public HornetQConnectionFactory(boolean ha,
                        DiscoveryGroupConfiguration groupConfiguration)

HornetQConnectionFactory

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

Method Detail

createConnection

public Connection createConnection()
                            throws JMSException

Throws:: JMSException

createConnection

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

Throws:: JMSException

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

Throws:: JMSException

createXAConnection

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

Throws:: JMSException

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)

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)

setGroupID

public void setGroupID(String groupID)

getGroupID
```
public String getGroupID()
```

isCompressLargeMessage

public boolean isCompressLargeMessage()

setCompressLargeMessage

public void setCompressLargeMessage(boolean compress)

close
```
public void close()
```

getServerLocator

public ServerLocator getServerLocator()

getFactoryType
```
public int getFactoryType()
```

getCoreFactory

@Deprecated
public ClientSessionFactory getCoreFactory()
                                    throws JMSException

Deprecated. use ServerLocator.createSessionFactory()

Returns:
Throws:: JMSException

createConnectionInternal

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

Throws:: JMSException

toString
```
public String toString()
```
Overrides:

toString in class Object

finalize

public void finalize()
              throws Throwable

Overrides:: finalize in class Object
Throws:: Throwable

Class HornetQConnectionFactory

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

HornetQConnectionFactory

HornetQConnectionFactory

HornetQConnectionFactory

HornetQConnectionFactory

Method Detail

createConnection

createConnection

createQueueConnection

createQueueConnection

createTopicConnection

createTopicConnection

createXAConnection

createXAConnection

createXAQueueConnection

createXAQueueConnection

createXATopicConnection

createXATopicConnection

getReference

isHA

getConnectionLoadBalancingPolicyClassName

setConnectionLoadBalancingPolicyClassName

getStaticConnectors

getDiscoveryGroupConfiguration

getClientID

setClientID

getDupsOKBatchSize

setDupsOKBatchSize

getTransactionBatchSize

setTransactionBatchSize

getClientFailureCheckPeriod

setClientFailureCheckPeriod

getConnectionTTL

setConnectionTTL

getCallTimeout

setCallTimeout

getConsumerWindowSize

setConsumerWindowSize

getConsumerMaxRate

setConsumerMaxRate

getConfirmationWindowSize

setConfirmationWindowSize

getProducerMaxRate

setProducerMaxRate

getProducerWindowSize

setProducerWindowSize

setCacheLargeMessagesClient

isCacheLargeMessagesClient

getMinLargeMessageSize

setMinLargeMessageSize

isBlockOnAcknowledge

setBlockOnAcknowledge

isBlockOnNonDurableSend

setBlockOnNonDurableSend

isBlockOnDurableSend

setBlockOnDurableSend

isAutoGroup

setAutoGroup

isPreAcknowledge

setPreAcknowledge

getRetryInterval

setRetryInterval

getMaxRetryInterval

setMaxRetryInterval

getRetryIntervalMultiplier

setRetryIntervalMultiplier

getReconnectAttempts

setReconnectAttempts

setInitialConnectAttempts

getInitialConnectAttempts

isFailoverOnInitialConnection

setFailoverOnInitialConnection

isUseGlobalPools

setUseGlobalPools

getScheduledThreadPoolMaxSize

setScheduledThreadPoolMaxSize