org.jboss.messaging.core.client
Interface ClientSessionFactory

All Known Subinterfaces:
ClientSessionFactoryInternal
All Known Implementing Classes:
ClientSessionFactoryImpl

public interface ClientSessionFactory

A ClientSessionFactory

Author:
Tim Fox

Method Summary
 void close()
           
 ClientSession createSession()
           
 ClientSession createSession(boolean autoCommitSends, boolean autoCommitAcks)
           
 ClientSession createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks)
           
 ClientSession createSession(boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge)
           
 ClientSession createSession(java.lang.String username, java.lang.String password, boolean xa, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, int ackBatchSize)
           
 ClientSession createTransactedSession()
           
 ClientSession createXASession()
           
 int getAckBatchSize()
           
 long getCallTimeout()
           
 long getClientFailureCheckPeriod()
           
 java.lang.String getConnectionLoadBalancingPolicyClassName()
           
 long getConnectionTTL()
           
 int getConsumerMaxRate()
           
 int getConsumerWindowSize()
           
 java.lang.String getDiscoveryAddress()
           
 long getDiscoveryInitialWaitTimeout()
           
 int getDiscoveryPort()
           
 long getDiscoveryRefreshTimeout()
           
 int getMaxConnections()
           
 int getMinLargeMessageSize()
           
 int getProducerMaxRate()
           
 int getProducerWindowSize()
           
 int getReconnectAttempts()
           
 long getRetryInterval()
           
 double getRetryIntervalMultiplier()
           
 int getScheduledThreadPoolMaxSize()
           
 java.util.List<Pair<TransportConfiguration,TransportConfiguration>> getStaticConnectors()
           
 int getThreadPoolMaxSize()
           
 boolean isAutoGroup()
           
 boolean isBlockOnAcknowledge()
           
 boolean isBlockOnNonPersistentSend()
           
 boolean isBlockOnPersistentSend()
           
 boolean isFailoverOnServerShutdown()
           
 boolean isPreAcknowledge()
           
 boolean isUseGlobalPools()
           
 void setAckBatchSize(int ackBatchSize)
           
 void setAutoGroup(boolean autoGroup)
           
 void setBlockOnAcknowledge(boolean blockOnAcknowledge)
           
 void setBlockOnNonPersistentSend(boolean blockOnNonPersistentSend)
           
 void setBlockOnPersistentSend(boolean blockOnPersistentSend)
           
 void setCallTimeout(long callTimeout)
           
 void setClientFailureCheckPeriod(long clientFailureCheckPeriod)
           
 void setConnectionLoadBalancingPolicyClassName(java.lang.String loadBalancingPolicyClassName)
           
 void setConnectionTTL(long connectionTTL)
           
 void setConsumerMaxRate(int consumerMaxRate)
           
 void setConsumerWindowSize(int consumerWindowSize)
           
 void setDiscoveryAddress(java.lang.String discoveryAddress)
           
 void setDiscoveryInitialWaitTimeout(long initialWaitTimeout)
           
 void setDiscoveryPort(int discoveryPort)
           
 void setDiscoveryRefreshTimeout(long discoveryRefreshTimeout)
           
 void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)
           
 void setMaxConnections(int maxConnections)
           
 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 setStaticConnectors(java.util.List<Pair<TransportConfiguration,TransportConfiguration>> staticConnectors)
           
 void setThreadPoolMaxSize(int threadPoolMaxSize)
           
 void setUseGlobalPools(boolean useGlobalPools)
           
 

Method Detail

createXASession

ClientSession createXASession()
                              throws MessagingException
Throws:
MessagingException

createTransactedSession

ClientSession createTransactedSession()
                                      throws MessagingException
Throws:
MessagingException

createSession

ClientSession createSession()
                            throws MessagingException
Throws:
MessagingException

createSession

ClientSession createSession(boolean autoCommitSends,
                            boolean autoCommitAcks)
                            throws MessagingException
Throws:
MessagingException

createSession

ClientSession createSession(boolean xa,
                            boolean autoCommitSends,
                            boolean autoCommitAcks)
                            throws MessagingException
Throws:
MessagingException

createSession

ClientSession createSession(java.lang.String username,
                            java.lang.String password,
                            boolean xa,
                            boolean autoCommitSends,
                            boolean autoCommitAcks,
                            boolean preAcknowledge,
                            int ackBatchSize)
                            throws MessagingException
Throws:
MessagingException

createSession

ClientSession createSession(boolean xa,
                            boolean autoCommitSends,
                            boolean autoCommitAcks,
                            boolean preAcknowledge)
                            throws MessagingException
Throws:
MessagingException

getStaticConnectors

java.util.List<Pair<TransportConfiguration,TransportConfiguration>> getStaticConnectors()

setStaticConnectors

void setStaticConnectors(java.util.List<Pair<TransportConfiguration,TransportConfiguration>> staticConnectors)

getClientFailureCheckPeriod

long getClientFailureCheckPeriod()

setClientFailureCheckPeriod

void setClientFailureCheckPeriod(long clientFailureCheckPeriod)

getConnectionTTL

long getConnectionTTL()

setConnectionTTL

void setConnectionTTL(long connectionTTL)

getCallTimeout

long getCallTimeout()

setCallTimeout

void setCallTimeout(long callTimeout)

getMaxConnections

int getMaxConnections()

setMaxConnections

void setMaxConnections(int maxConnections)

getMinLargeMessageSize

int getMinLargeMessageSize()

setMinLargeMessageSize

void setMinLargeMessageSize(int minLargeMessageSize)

getConsumerWindowSize

int getConsumerWindowSize()

setConsumerWindowSize

void setConsumerWindowSize(int consumerWindowSize)

getConsumerMaxRate

int getConsumerMaxRate()

setConsumerMaxRate

void setConsumerMaxRate(int consumerMaxRate)

getProducerWindowSize

int getProducerWindowSize()

setProducerWindowSize

void setProducerWindowSize(int producerWindowSize)

getProducerMaxRate

int getProducerMaxRate()

setProducerMaxRate

void setProducerMaxRate(int producerMaxRate)

isBlockOnAcknowledge

boolean isBlockOnAcknowledge()

setBlockOnAcknowledge

void setBlockOnAcknowledge(boolean blockOnAcknowledge)

isBlockOnPersistentSend

boolean isBlockOnPersistentSend()

setBlockOnPersistentSend

void setBlockOnPersistentSend(boolean blockOnPersistentSend)

isBlockOnNonPersistentSend

boolean isBlockOnNonPersistentSend()

setBlockOnNonPersistentSend

void setBlockOnNonPersistentSend(boolean blockOnNonPersistentSend)

isAutoGroup

boolean isAutoGroup()

setAutoGroup

void setAutoGroup(boolean autoGroup)

isPreAcknowledge

boolean isPreAcknowledge()

setPreAcknowledge

void setPreAcknowledge(boolean preAcknowledge)

getAckBatchSize

int getAckBatchSize()

setAckBatchSize

void setAckBatchSize(int ackBatchSize)

getDiscoveryInitialWaitTimeout

long getDiscoveryInitialWaitTimeout()

setDiscoveryInitialWaitTimeout

void setDiscoveryInitialWaitTimeout(long initialWaitTimeout)

isUseGlobalPools

boolean isUseGlobalPools()

setUseGlobalPools

void setUseGlobalPools(boolean useGlobalPools)

getScheduledThreadPoolMaxSize

int getScheduledThreadPoolMaxSize()

setScheduledThreadPoolMaxSize

void setScheduledThreadPoolMaxSize(int scheduledThreadPoolMaxSize)

getThreadPoolMaxSize

int getThreadPoolMaxSize()

setThreadPoolMaxSize

void setThreadPoolMaxSize(int threadPoolMaxSize)

getRetryInterval

long getRetryInterval()

setRetryInterval

void setRetryInterval(long retryInterval)

getRetryIntervalMultiplier

double getRetryIntervalMultiplier()

setRetryIntervalMultiplier

void setRetryIntervalMultiplier(double retryIntervalMultiplier)

getReconnectAttempts

int getReconnectAttempts()

setReconnectAttempts

void setReconnectAttempts(int reconnectAttempts)

isFailoverOnServerShutdown

boolean isFailoverOnServerShutdown()

setFailoverOnServerShutdown

void setFailoverOnServerShutdown(boolean failoverOnServerShutdown)

getConnectionLoadBalancingPolicyClassName

java.lang.String getConnectionLoadBalancingPolicyClassName()

setConnectionLoadBalancingPolicyClassName

void setConnectionLoadBalancingPolicyClassName(java.lang.String loadBalancingPolicyClassName)

getDiscoveryAddress

java.lang.String getDiscoveryAddress()

setDiscoveryAddress

void setDiscoveryAddress(java.lang.String discoveryAddress)

getDiscoveryPort

int getDiscoveryPort()

setDiscoveryPort

void setDiscoveryPort(int discoveryPort)

getDiscoveryRefreshTimeout

long getDiscoveryRefreshTimeout()

setDiscoveryRefreshTimeout

void setDiscoveryRefreshTimeout(long discoveryRefreshTimeout)

close

void close()


Copyright © 2006 JBoss Inc. All Rights Reserved.