Package 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	Description
void	addFailureListener(SessionFailureListener listener)
void	causeExit()
void	connect(int reconnectAttempts)
void	connect(int reconnectAttempts, boolean failoverOnInitialConnection)	Deprecated. This method is no longer acceptable to connect.
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	waitForRetry(long interval)
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, 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)

getLiveNodeId

String getLiveNodeId()

numConnections

int numConnections()

numSessions

int numSessions()

removeSession

void removeSession(ClientSessionInternal session,
                   boolean failingOver)

connect

void connect(int reconnectAttempts)
      throws ActiveMQException

Throws:

ActiveMQException

connect

@Deprecated
void connect(int reconnectAttempts,
             boolean failoverOnInitialConnection)
      throws ActiveMQException

Deprecated.

This method is no longer acceptable to connect. Replaced by connect(int).

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()

waitForRetry

boolean waitForRetry(long interval)