org.nuxeo.ecm.core.storage.sql.jdbc

Class JDBCConnectionPropagator

java.lang.Object

org.nuxeo.ecm.core.storage.sql.jdbc.JDBCConnectionPropagator

public class JDBCConnectionPropagator
extends Object

Knows all the JDBCConnections in use by a backend, so that they can notify each other when there's a connection failure.

Field Summary

Fields

Modifier and Type	Field and Description
ClusterNodeHandler	clusterNodeHandler
List<JDBCConnection>	connections

Constructor Summary

Constructors

Constructor and Description
JDBCConnectionPropagator()

Method Summary

Methods

Modifier and Type	Method and Description
void	addConnection(JDBCConnection connection)
void	connectionWasReset(JDBCConnection connection) Notifies all connection that they must check their validity.
void	removeConnection(JDBCConnection connection)
void	setClusterNodeHandler(ClusterNodeHandler clusterNodeHandler)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connections

public final List<JDBCConnection> connections

clusterNodeHandler

public ClusterNodeHandler clusterNodeHandler

Constructor Detail

JDBCConnectionPropagator

public JDBCConnectionPropagator()

Method Detail

addConnection

public void addConnection(JDBCConnection connection)

setClusterNodeHandler

public void setClusterNodeHandler(ClusterNodeHandler clusterNodeHandler)

removeConnection

public void removeConnection(JDBCConnection connection)

connectionWasReset

public void connectionWasReset(JDBCConnection connection)
                        throws StorageException

Notifies all connection that they must check their validity.

Parameters:

connection - the connection that was reset

Throws:

StorageException