Interface ClientSessionFactoryInternal
- All Superinterfaces:
AutoCloseable,ClientSessionFactory
- All Known Implementing Classes:
ClientSessionFactoryImpl
-
Method Summary
Modifier and TypeMethodDescriptionvoidaddFailureListener(SessionFailureListener listener) voidvoidconnect(int reconnectAttempts) voidconnect(int reconnectAttempts, boolean failoverOnInitialConnection) Deprecated.This method is no longer acceptable to connect.intintbooleanremoveFailureListener(SessionFailureListener listener) voidremoveSession(ClientSessionInternal session, boolean failingOver) voidsetBackupConnector(TransportConfiguration live, TransportConfiguration backUp) voidsetReconnectAttempts(int i) booleanwaitForRetry(long interval) booleanwaitForTopology(long timeout, TimeUnit unit) Methods inherited from interface org.apache.activemq.artemis.api.core.client.ClientSessionFactory
addFailoverListener, cleanup, close, createSession, createSession, createSession, createSession, createSession, createSession, createSession, createTransactedSession, createXASession, getConnection, getConnectorConfiguration, getServerLocator, isClosed, removeFailoverListener
-
Method Details
-
causeExit
void causeExit() -
addFailureListener
-
removeFailureListener
-
waitForTopology
-
getPrimaryNodeId
String getPrimaryNodeId() -
numConnections
int numConnections() -
numSessions
int numSessions() -
removeSession
-
connect
- Throws:
ActiveMQException
-
connect
@Deprecated void connect(int reconnectAttempts, boolean failoverOnInitialConnection) throws ActiveMQException Deprecated.This method is no longer acceptable to connect. Replaced byconnect(int).- Throws:
ActiveMQException
-
setBackupConnector
-
getConnector
Object getConnector() -
getBackupConnector
Object getBackupConnector() -
setReconnectAttempts
void setReconnectAttempts(int i) -
getConfirmationWindowWarning
ConfirmationWindowWarning getConfirmationWindowWarning() -
lockFailover
Lock lockFailover() -
waitForRetry
boolean waitForRetry(long interval)
-