org.apache.activemq.artemis.core.client.impl

Interface ClientSessionFactoryInternal

All Superinterfaces:

AutoCloseable, ClientSessionFactory

All Known Implementing Classes:

ClientSessionFactoryImpl

public interface ClientSessionFactoryInternal
extends ClientSessionFactory

Method Summary

Modifier and Type	Method and Description
void	addFailureListener(SessionFailureListener listener)
void	causeExit()
void	connect(int reconnectAttempts, boolean failoverOnInitialConnection)
void	disableFinalizeCheck()
Object	getBackupConnector()
ConfirmationWindowWarning	getConfirmationWindowWarning()
Object	getConnector()
String	getLiveNodeId()
Lock	lockFailover()
int	numConnections()
int	numSessions()
boolean	removeFailureListener(SessionFailureListener listener)
void	removeSession(ClientSessionInternal session, boolean failingOver)
void	setBackupConnector(TransportConfiguration live, TransportConfiguration backUp)
void	setReconnectAttempts(int i)
boolean	waitForTopology(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, createTransactedSession, createXASession, getConnection, getConnectorConfiguration, getServerLocator, isClosed, removeFailoverListener

Method Detail

causeExit

void causeExit()

addFailureListener

void addFailureListener(SessionFailureListener listener)

removeFailureListener

boolean removeFailureListener(SessionFailureListener listener)

waitForTopology

boolean waitForTopology(long timeout,
                        TimeUnit unit)

disableFinalizeCheck

void disableFinalizeCheck()

getLiveNodeId

String getLiveNodeId()

numConnections

int numConnections()

numSessions

int numSessions()

removeSession

void removeSession(ClientSessionInternal session,
                   boolean failingOver)

connect

void connect(int reconnectAttempts,
             boolean failoverOnInitialConnection)
      throws ActiveMQException

Throws:

ActiveMQException

setBackupConnector

void setBackupConnector(TransportConfiguration live,
                        TransportConfiguration backUp)

getConnector

Object getConnector()

getBackupConnector

Object getBackupConnector()

setReconnectAttempts

void setReconnectAttempts(int i)

getConfirmationWindowWarning

ConfirmationWindowWarning getConfirmationWindowWarning()

lockFailover

Lock lockFailover()