org.hornetq.core.client.impl

Interface ClientSessionFactoryInternal

All Superinterfaces:

ClientSessionFactory

All Known Implementing Classes:

ClientSessionFactoryImpl

public interface ClientSessionFactoryInternal
extends ClientSessionFactory

A ClientSessionFactoryInternal

Author:

Tim Fox

Method Summary

Methods

Modifier and Type	Method and Description
void	addFailureListener(SessionFailureListener listener)
void	causeExit()
void	connect(int reconnectAttempts, boolean failoverOnInitialConnection)
void	disableFinalizeCheck()
Object	getBackupConnector()
TransportConfiguration	getConnectorConfiguration()
int	numConnections()
int	numSessions()
boolean	removeFailureListener(SessionFailureListener listener)
void	removeSession(ClientSessionInternal session, boolean failingOver)
void	sendNodeAnnounce(long currentEventID, String nodeID, boolean isBackup, TransportConfiguration config, TransportConfiguration backupConfig)
void	setBackupConnector(TransportConfiguration live, TransportConfiguration backUp)
void	setReconnectAttempts(int i)

Methods inherited from interface org.hornetq.api.core.client.ClientSessionFactory

cleanup, close, createSession, createSession, createSession, createSession, createSession, createSession, createTransactedSession, createXASession, getConnection, getServerLocator, isClosed

Method Detail

causeExit

void causeExit()

addFailureListener

void addFailureListener(SessionFailureListener listener)

removeFailureListener

boolean removeFailureListener(SessionFailureListener listener)

disableFinalizeCheck

void disableFinalizeCheck()

numConnections

int numConnections()

numSessions

int numSessions()

removeSession

void removeSession(ClientSessionInternal session,
                 boolean failingOver)

connect

void connect(int reconnectAttempts,
           boolean failoverOnInitialConnection)
             throws HornetQException

Throws:

HornetQException

sendNodeAnnounce

void sendNodeAnnounce(long currentEventID,
                    String nodeID,
                    boolean isBackup,
                    TransportConfiguration config,
                    TransportConfiguration backupConfig)

getConnectorConfiguration

TransportConfiguration getConnectorConfiguration()

setBackupConnector

void setBackupConnector(TransportConfiguration live,
                      TransportConfiguration backUp)

getBackupConnector

Object getBackupConnector()

setReconnectAttempts

void setReconnectAttempts(int i)