org.hornetq.core.server.impl

Class FileLockNodeManager

java.lang.Object

org.hornetq.core.server.NodeManager

org.hornetq.core.server.impl.FileLockNodeManager

All Implemented Interfaces:

HornetQComponent

Direct Known Subclasses:

AIOFileLockNodeManager

public class FileLockNodeManager
extends NodeManager

Author:

Andy Taylor Date: Oct 13, 2010 Time: 2:44:02 PM

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	interrupted
protected static String	SERVER_LOCK_NAME

Fields inherited from class org.hornetq.core.server.NodeManager

nodeID, uuid

Constructor Summary

Constructors

Constructor and Description
FileLockNodeManager(String directory)

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitLiveNode()
void	crashLiveServer()
String	getDirectory()
void	interrupt()
boolean	isAwaitingFailback()
boolean	isBackupLive()
boolean	isLiveLocked()
protected FileLock	lock(int liveLockPos)
protected File	newFile(String fileName)
void	pauseLiveServer()
void	releaseBackup()
void	start()
void	startBackup()
void	startLiveNode()
void	stop()
void	stopBackup()
protected FileLock	tryLock(int lockPos)

Methods inherited from class org.hornetq.core.server.NodeManager

getNodeId, getUUID, isStarted

Methods inherited from class java.lang.Object

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

Field Detail

SERVER_LOCK_NAME

protected static final String SERVER_LOCK_NAME

See Also:

Constant Field Values

interrupted

protected boolean interrupted

Constructor Detail

FileLockNodeManager

public FileLockNodeManager(String directory)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Overrides:

start in class NodeManager

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Overrides:

stop in class NodeManager

Throws:

Exception

isAwaitingFailback

public boolean isAwaitingFailback()
                           throws Exception

Specified by:

isAwaitingFailback in class NodeManager

Throws:

Exception

isBackupLive

public boolean isBackupLive()
                     throws Exception

Specified by:

isBackupLive in class NodeManager

Throws:

Exception

isLiveLocked

public boolean isLiveLocked()

interrupt

public void interrupt()

Specified by:

interrupt in class NodeManager

releaseBackup

public void releaseBackup()
                   throws Exception

Specified by:

releaseBackup in class NodeManager

Throws:

Exception

awaitLiveNode

public void awaitLiveNode()
                   throws Exception

Specified by:

awaitLiveNode in class NodeManager

Throws:

Exception

startBackup

public void startBackup()
                 throws Exception

Specified by:

startBackup in class NodeManager

Throws:

Exception

startLiveNode

public void startLiveNode()
                   throws Exception

Specified by:

startLiveNode in class NodeManager

Throws:

Exception

pauseLiveServer

public void pauseLiveServer()
                     throws Exception

Specified by:

pauseLiveServer in class NodeManager

Throws:

Exception

crashLiveServer

public void crashLiveServer()
                     throws Exception

Specified by:

crashLiveServer in class NodeManager

Throws:

Exception

stopBackup

public void stopBackup()
                throws Exception

Specified by:

stopBackup in class NodeManager

Throws:

Exception

getDirectory

public String getDirectory()

newFile

protected File newFile(String fileName)

Returns:

tryLock

protected FileLock tryLock(int lockPos)
                    throws Exception

Throws:

Exception

lock

protected FileLock lock(int liveLockPos)
                 throws IOException

Throws:

IOException