step.grid

Class Grid

java.lang.Object

step.grid.Grid

All Implemented Interfaces:

TokenRegistry

public class Grid
extends Object
implements TokenRegistry

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOCAL_AGENT

Constructor Summary

Constructors

Constructor and Description
Grid(File fileManagerFolder, Integer port)
Grid(File fileManagerFolder, Integer port, Integer ttl)
Grid(Integer port)

Method Summary

Modifier and Type	Method and Description
Collection<AgentRef>	getAgents()
FileManager	getFileManager()
int	getServerPort()
List<Token<TokenWrapper>>	getTokens()
protected void	handleRegistrationMessage(RegistrationMessage message)
void	markTokenAsFailing(String tokenId, String errorMessage, Exception e)
void	removeTokenError(String tokenId)
void	returnToken(TokenWrapper object)
TokenWrapper	selectToken(Identity pretender, long matchTimeout, long noMatchTimeout)
void	start()
void	startTokenMaintenance(String tokenId)
void	stop()
void	stopTokenMaintenance(String tokenId)

Methods inherited from class java.lang.Object

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

Field Detail

LOCAL_AGENT

public static final String LOCAL_AGENT

See Also:

Constant Field Values

Constructor Detail

Grid

public Grid(Integer port)

Grid

public Grid(File fileManagerFolder,
            Integer port)

Grid

public Grid(File fileManagerFolder,
            Integer port,
            Integer ttl)

Method Detail

stop

public void stop()
          throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Throws:

Exception

handleRegistrationMessage

protected void handleRegistrationMessage(RegistrationMessage message)

selectToken

public TokenWrapper selectToken(Identity pretender,
                                long matchTimeout,
                                long noMatchTimeout)
                         throws TimeoutException,
                                InterruptedException

Specified by:

selectToken in interface TokenRegistry

Throws:

TimeoutException

InterruptedException

returnToken

public void returnToken(TokenWrapper object)

Specified by:

returnToken in interface TokenRegistry

markTokenAsFailing

public void markTokenAsFailing(String tokenId,
                               String errorMessage,
                               Exception e)

Specified by:

markTokenAsFailing in interface TokenRegistry

removeTokenError

public void removeTokenError(String tokenId)

startTokenMaintenance

public void startTokenMaintenance(String tokenId)

stopTokenMaintenance

public void stopTokenMaintenance(String tokenId)

getTokens

public List<Token<TokenWrapper>> getTokens()

Specified by:

getTokens in interface TokenRegistry

getAgents

public Collection<AgentRef> getAgents()

getServerPort

public int getServerPort()

getFileManager

public FileManager getFileManager()