com.continuent.tungsten.replicator.thl.log
Class LogConnectionManager

java.lang.Object
  extended by com.continuent.tungsten.replicator.thl.log.LogConnectionManager

public class LogConnectionManager
extends java.lang.Object

Encapsulates management of connections and their log cursors. Log cursors are a position in a particular log file and can only move in a forward direction. If clients move backward in the log we need to allocated a new cursor.

Author:
Robert Hodges

Constructor Summary
LogConnectionManager()
          Create a new log cursor manager.
 
Method Summary
 void release(LogConnection connection)
          Releases an existing connection.
 void releaseAll()
          Releases all connections.
 void store(LogConnection connection)
          Stores a new connection.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LogConnectionManager

public LogConnectionManager()
Create a new log cursor manager.

Method Detail

store

public void store(LogConnection connection)
           throws ReplicatorException
Stores a new connection.

Throws:
ReplicatorException

release

public void release(LogConnection connection)
Releases an existing connection.


releaseAll

public void releaseAll()
Releases all connections. This must be called when terminating to ensure file descriptors are released.