public class _SharedResourcesTie extends _SharedResourcesDisp implements Ice.TieBase
Modifier and Type | Field and Description |
---|---|
static long |
serialVersionUID |
__ids
ice_staticId
Constructor and Description |
---|
_SharedResourcesTie(_SharedResourcesOperations delegate) |
_SharedResourcesTie() |
Modifier and Type | Method and Description |
---|---|
InteractiveProcessorPrx |
acquireProcessor(Job job,
int seconds,
Ice.Current __current)
Waits up to seconds to acquire a slot in a processor
which can handle the given job.
|
void |
addProcessor(ProcessorPrx proc,
Ice.Current __current)
Registers a
Processor for Storm notifications
so that other sessions can query whether or not a given
processor would accept a given task. |
boolean |
areTablesEnabled(Ice.Current __current)
Returns true if a
Tables service is active in the grid. |
boolean |
equals(java.lang.Object rhs) |
RepositoryPrx |
getScriptRepository(Ice.Current __current)
Returns the single (possibly mirrored) script repository which makes
all official scripts available.
|
int |
hashCode() |
java.lang.Object |
ice_delegate() |
void |
ice_delegate(java.lang.Object delegate) |
TablePrx |
newTable(long repoId,
java.lang.String path,
Ice.Current __current)
Creates a new Format(""OMERO.tables"") file at the given path
on the given repository.
|
TablePrx |
openTable(OriginalFile file,
Ice.Current __current)
Returns a Table instance or null.
|
void |
removeProcessor(ProcessorPrx proc,
Ice.Current __current)
Unregisters a
Processor from Storm
notifications. |
RepositoryMap |
repositories(Ice.Current __current)
Returns a map between Repository descriptions (omero::model::OriginalFile
instances) and RepositoryPrx instances (possibly null).
|
___acquireProcessor, ___addProcessor, ___areTablesEnabled, ___getScriptRepository, ___newTable, ___openTable, ___removeProcessor, ___repositories, __dispatch, __readImpl, __writeImpl, acquireProcessor, addProcessor, areTablesEnabled, getScriptRepository, ice_copyStateFrom, ice_id, ice_id, ice_ids, ice_ids, ice_isA, ice_isA, ice_staticId, newTable, openTable, removeProcessor, repositories
___ice_id, ___ice_ids, ___ice_isA, ___ice_ping, __checkMode, __read, __read, __readImpl, __write, __write, __writeImpl, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal
public static final long serialVersionUID
public _SharedResourcesTie()
public _SharedResourcesTie(_SharedResourcesOperations delegate)
public java.lang.Object ice_delegate()
ice_delegate
in interface Ice.TieBase
public void ice_delegate(java.lang.Object delegate)
ice_delegate
in interface Ice.TieBase
public boolean equals(java.lang.Object rhs)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public InteractiveProcessorPrx acquireProcessor(Job job, int seconds, Ice.Current __current) throws ServerError
_SharedResourcesOperations
acquireProcessor
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public void addProcessor(ProcessorPrx proc, Ice.Current __current) throws ServerError
_SharedResourcesOperations
Processor
for Storm notifications
so that other sessions can query whether or not a given
processor would accept a given task.addProcessor
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public boolean areTablesEnabled(Ice.Current __current) throws ServerError
_SharedResourcesOperations
Tables
service is active in the grid.
If this value is false, then all calls to #ewTable
or openTable
will either fail or return null (possibly
blocking while waiting for a service to startup)areTablesEnabled
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public RepositoryPrx getScriptRepository(Ice.Current __current) throws ServerError
_SharedResourcesOperations
getScriptRepository
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public TablePrx newTable(long repoId, java.lang.String path, Ice.Current __current) throws ServerError
_SharedResourcesOperations
newTable
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public TablePrx openTable(OriginalFile file, Ice.Current __current) throws ServerError
_SharedResourcesOperations
openTable
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public void removeProcessor(ProcessorPrx proc, Ice.Current __current) throws ServerError
_SharedResourcesOperations
Processor
from Storm
notifications. If the processor was not already registered via
addProcessor
this is a no-op.removeProcessor
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError
public RepositoryMap repositories(Ice.Current __current) throws ServerError
_SharedResourcesOperations
repositories
in interface _SharedResourcesOperations
__current
- The Current object for the invocation.ServerError