step.grid.client

Class GridClientImpl

java.lang.Object

step.grid.client.GridClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, GridClient, GridFileService

public class GridClientImpl
extends Object
implements GridClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GridClientImpl.AgentCallTimeoutException
static class	GridClientImpl.AgentCommunicationException
static class	GridClientImpl.AgentSideException

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentTokenServices	localAgentTokenServices
protected MessageHandlerPool	localMessageHandlerPool
protected ConcurrentHashMap<String,TokenReservationSession>	localTokenSessions
static String	SELECTION_CRITERION_THREAD

Constructor Summary

Constructors

Constructor and Description
GridClientImpl(Grid grid)
GridClientImpl(GridClientConfiguration gridClientConfiguration, Grid grid)
GridClientImpl(GridClientConfiguration gridClientConfiguration, TokenLifecycleStrategy tokenLifecycleStrategy, Grid grid)

Method Summary

Modifier and Type	Method and Description
OutputMessage	call(TokenWrapper tokenWrapper, com.fasterxml.jackson.databind.JsonNode argument, String handler, FileVersionId handlerPackage, Map<String,String> properties, int callTimeout)
void	close()
TokenWrapper	getLocalTokenHandle()
FileVersion	getRegisteredFile(FileVersionId fileVersionId) Get a file that has been previously registered to the GRID
TokenWrapper	getTokenHandle(Map<String,String> attributes, Map<String,Interest> interests, boolean createSession)
protected TokenLifecycleStrategyCallback	getTokenLifecycleCallback(TokenWrapper tokenWrapper)
protected boolean	isLocal(TokenWrapper tokenWrapper)
FileVersion	registerFile(File file) Register a file into the GRID
void	returnTokenHandle(TokenWrapper tokenWrapper)

Methods inherited from class java.lang.Object

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

Field Detail

SELECTION_CRITERION_THREAD

public static final String SELECTION_CRITERION_THREAD

See Also:

Constant Field Values

localTokenSessions

protected ConcurrentHashMap<String,TokenReservationSession> localTokenSessions

localAgentTokenServices

protected AgentTokenServices localAgentTokenServices

localMessageHandlerPool

protected MessageHandlerPool localMessageHandlerPool

Constructor Detail

GridClientImpl

public GridClientImpl(Grid grid)

GridClientImpl

public GridClientImpl(GridClientConfiguration gridClientConfiguration,
                      Grid grid)

GridClientImpl

public GridClientImpl(GridClientConfiguration gridClientConfiguration,
                      TokenLifecycleStrategy tokenLifecycleStrategy,
                      Grid grid)

Method Detail

getLocalTokenHandle

public TokenWrapper getLocalTokenHandle()

Specified by:

getLocalTokenHandle in interface GridClient

getTokenHandle

public TokenWrapper getTokenHandle(Map<String,String> attributes,
                                   Map<String,Interest> interests,
                                   boolean createSession)
                            throws GridClientImpl.AgentCommunicationException

Specified by:

getTokenHandle in interface GridClient

Throws:

GridClientImpl.AgentCommunicationException

returnTokenHandle

public void returnTokenHandle(TokenWrapper tokenWrapper)
                       throws GridClientImpl.AgentCommunicationException

Specified by:

returnTokenHandle in interface GridClient

Throws:

GridClientImpl.AgentCommunicationException

isLocal

protected boolean isLocal(TokenWrapper tokenWrapper)

call

public OutputMessage call(TokenWrapper tokenWrapper,
                          com.fasterxml.jackson.databind.JsonNode argument,
                          String handler,
                          FileVersionId handlerPackage,
                          Map<String,String> properties,
                          int callTimeout)
                   throws Exception

Specified by:

call in interface GridClient

Throws:

Exception

getTokenLifecycleCallback

protected TokenLifecycleStrategyCallback getTokenLifecycleCallback(TokenWrapper tokenWrapper)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface GridClient

registerFile

public FileVersion registerFile(File file)
                         throws FileManagerException

Description copied from interface: GridFileService

Register a file into the GRID

Specified by:

registerFile in interface GridFileService

Parameters:

file - the file to be registered to the GRID

Returns:

an handle to the registered file. This handle will be used to retrieve the registered file

Throws:

FileManagerException

getRegisteredFile

public FileVersion getRegisteredFile(FileVersionId fileVersionId)
                              throws FileManagerException

Description copied from interface: GridFileService

Get a file that has been previously registered to the GRID

Specified by:

getRegisteredFile in interface GridFileService

Parameters:

fileVersionId - the handle returned at regitration

Returns:

the registered file

Throws:

FileManagerException