public class HornetQConnectionFactory extends Object implements Serializable, Referenceable, javax.jms.ConnectionFactory, javax.jms.XAConnectionFactory
Constructor and Description |
---|
HornetQConnectionFactory() |
HornetQConnectionFactory(boolean ha,
DiscoveryGroupConfiguration groupConfiguration) |
HornetQConnectionFactory(boolean ha,
TransportConfiguration... initialConnectors) |
HornetQConnectionFactory(ServerLocator serverLocator) |
public HornetQConnectionFactory()
public HornetQConnectionFactory(ServerLocator serverLocator)
public HornetQConnectionFactory(boolean ha, DiscoveryGroupConfiguration groupConfiguration)
public HornetQConnectionFactory(boolean ha, TransportConfiguration... initialConnectors)
public javax.jms.Connection createConnection() throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
public javax.jms.Connection createConnection(String username, String password) throws javax.jms.JMSException
createConnection
in interface javax.jms.ConnectionFactory
javax.jms.JMSException
public javax.jms.JMSContext createContext()
createContext
in interface javax.jms.ConnectionFactory
public javax.jms.JMSContext createContext(int sessionMode)
createContext
in interface javax.jms.ConnectionFactory
public javax.jms.JMSContext createContext(String userName, String password)
createContext
in interface javax.jms.ConnectionFactory
public javax.jms.JMSContext createContext(String userName, String password, int sessionMode)
createContext
in interface javax.jms.ConnectionFactory
public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.QueueConnection createQueueConnection(String username, String password) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicConnection createTopicConnection(String username, String password) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.XAConnection createXAConnection() throws javax.jms.JMSException
createXAConnection
in interface javax.jms.XAConnectionFactory
javax.jms.JMSException
public javax.jms.XAConnection createXAConnection(String username, String password) throws javax.jms.JMSException
createXAConnection
in interface javax.jms.XAConnectionFactory
javax.jms.JMSException
public javax.jms.XAJMSContext createXAContext()
createXAContext
in interface javax.jms.XAConnectionFactory
public javax.jms.XAJMSContext createXAContext(String userName, String password)
createXAContext
in interface javax.jms.XAConnectionFactory
public javax.jms.XAQueueConnection createXAQueueConnection() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.XAQueueConnection createXAQueueConnection(String username, String password) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.XATopicConnection createXATopicConnection() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.XATopicConnection createXATopicConnection(String username, String password) throws javax.jms.JMSException
javax.jms.JMSException
public Reference getReference() throws NamingException
getReference
in interface Referenceable
NamingException
public boolean isHA()
public String getConnectionLoadBalancingPolicyClassName()
public void setConnectionLoadBalancingPolicyClassName(String connectionLoadBalancingPolicyClassName)
public TransportConfiguration[] getStaticConnectors()
public DiscoveryGroupConfiguration getDiscoveryGroupConfiguration()
public String getClientID()
public void setClientID(String clientID)
public int getDupsOKBatchSize()
public void setDupsOKBatchSize(int dupsOKBatchSize)
public int getTransactionBatchSize()
public void setTransactionBatchSize(int transactionBatchSize)
public long getClientFailureCheckPeriod()
public void setClientFailureCheckPeriod(long clientFailureCheckPeriod)
public long getConnectionTTL()
public void setConnectionTTL(long connectionTTL)
public long getCallTimeout()
public void setCallTimeout(long callTimeout)
public long getCallFailoverTimeout()
public void setCallFailoverTimeout(long callTimeout)
public int getConsumerWindowSize()
public void setConsumerWindowSize(int consumerWindowSize)
public int getConsumerMaxRate()
public void setConsumerMaxRate(int consumerMaxRate)
public int getConfirmationWindowSize()
public void setConfirmationWindowSize(int confirmationWindowSize)
public int getProducerMaxRate()
public void setProducerMaxRate(int producerMaxRate)
public int getProducerWindowSize()
public void setProducerWindowSize(int producerWindowSize)
public void setCacheLargeMessagesClient(boolean cacheLargeMessagesClient)
cacheLargeMessagesClient
- public boolean isCacheLargeMessagesClient()
public int getMinLargeMessageSize()
public void setMinLargeMessageSize(int minLargeMessageSize)
public boolean isBlockOnAcknowledge()
public void setBlockOnAcknowledge(boolean blockOnAcknowledge)
public boolean isBlockOnNonDurableSend()
public void setBlockOnNonDurableSend(boolean blockOnNonDurableSend)
public boolean isBlockOnDurableSend()
public void setBlockOnDurableSend(boolean blockOnDurableSend)
public boolean isAutoGroup()
public void setAutoGroup(boolean autoGroup)
public boolean isPreAcknowledge()
public void setPreAcknowledge(boolean preAcknowledge)
public long getRetryInterval()
public void setRetryInterval(long retryInterval)
public long getMaxRetryInterval()
public void setMaxRetryInterval(long retryInterval)
public double getRetryIntervalMultiplier()
public void setRetryIntervalMultiplier(double retryIntervalMultiplier)
public int getReconnectAttempts()
public void setReconnectAttempts(int reconnectAttempts)
public void setInitialConnectAttempts(int reconnectAttempts)
public int getInitialConnectAttempts()
public boolean isFailoverOnInitialConnection()
public void setFailoverOnInitialConnection(boolean failover)
public boolean isUseGlobalPools()
public void setUseGlobalPools(boolean useGlobalPools)
public int getScheduledThreadPoolMaxSize()
public void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)
public int getThreadPoolMaxSize()
public void setThreadPoolMaxSize(int threadPoolMaxSize)
public int getInitialMessagePacketSize()
public void setInitialMessagePacketSize(int size)
public void setGroupID(String groupID)
public String getGroupID()
public boolean isCompressLargeMessage()
public void setCompressLargeMessage(boolean avoidLargeMessages)
public void close()
public ServerLocator getServerLocator()
public int getFactoryType()
protected HornetQConnection createConnectionInternal(String username, String password, boolean isXA, int type) throws javax.jms.JMSException
javax.jms.JMSException
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.