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
static String	SELECTION_CRITERION_THREAD

Constructor Summary

Constructors

Constructor and Description
GridClientImpl(GridClientConfiguration gridClientConfiguration, TokenRegistry tokenRegistry, GridFileService fileService)
GridClientImpl(GridClientConfiguration gridClientConfiguration, TokenRegistry tokenRegistry, TokenLifecycleStrategy tokenLifecycleStrategy, GridFileService fileService)
GridClientImpl(TokenRegistry tokenRegistry, GridFileService fileService)

Method Summary

Modifier and Type	Method and Description
OutputMessage	call(TokenWrapper tokenWrapper, String function, javax.json.JsonObject argument, String handler, FileManagerClient.FileVersionId handlerPackage, Map<String,String> properties, int callTimeout)
void	close()
TokenWrapper	getLocalTokenHandle()
File	getRegisteredFile(String fileHandle) 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)
String	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

localAgentTokenServices

protected AgentTokenServices localAgentTokenServices

localMessageHandlerPool

protected MessageHandlerPool localMessageHandlerPool

Constructor Detail

GridClientImpl

public GridClientImpl(TokenRegistry tokenRegistry,
                      GridFileService fileService)

GridClientImpl

public GridClientImpl(GridClientConfiguration gridClientConfiguration,
                      TokenRegistry tokenRegistry,
                      GridFileService fileService)

GridClientImpl

public GridClientImpl(GridClientConfiguration gridClientConfiguration,
                      TokenRegistry tokenRegistry,
                      TokenLifecycleStrategy tokenLifecycleStrategy,
                      GridFileService fileService)

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

call

public OutputMessage call(TokenWrapper tokenWrapper,
                          String function,
                          javax.json.JsonObject argument,
                          String handler,
                          FileManagerClient.FileVersionId handlerPackage,
                          Map<String,String> properties,
                          int callTimeout)
                   throws Exception

Specified by:

call in interface GridClient

Throws:

Exception

getTokenLifecycleCallback

protected TokenLifecycleStrategyCallback getTokenLifecycleCallback(TokenWrapper tokenWrapper)

registerFile

public String registerFile(File file)

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

getRegisteredFile

public File getRegisteredFile(String fileHandle)

Description copied from interface: GridFileService

Get a file that has been previously registered to the GRID

Specified by:

getRegisteredFile in interface GridFileService

Parameters:

fileHandle - the handle returned at regitration

Returns:

the registered file

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface GridClient