ome.services.blitz.repo

Class AbstractRepositoryI

java.lang.Object

Ice.ObjectImpl

omero.grid._InternalRepositoryDisp

ome.services.blitz.repo.AbstractRepositoryI

All Implemented Interfaces:

Ice.Object, Serializable, Cloneable, EventListener, omero.grid._InternalRepositoryOperations, omero.grid._InternalRepositoryOperationsNC, omero.grid.InternalRepository, org.springframework.context.ApplicationListener<InternalMessage>

Direct Known Subclasses:

InternalRepositoryI, LegacyRepositoryI, ScriptRepositoryI, TemporaryRepositoryI

public abstract class AbstractRepositoryI
extends omero.grid._InternalRepositoryDisp
implements org.springframework.context.ApplicationListener<InternalMessage>

Base repository class responsible for properly handling directory takeover and other lifecycle tasks. Individual instances will be responsible for providing the other service instances which are returned from this service.

Since:

Beta4.2

See Also:

Serialized Form

Field Summary

Fields inherited from class omero.grid._InternalRepositoryDisp

__ids, serialVersionUID

Constructor Summary

Constructors

Constructor and Description
AbstractRepositoryI(Ice.ObjectAdapter oa, Registry reg, Executor ex, Principal p, FileMaker fileMaker, PublicRepositoryI servant)
AbstractRepositoryI(Ice.ObjectAdapter oa, Registry reg, Executor ex, Principal p, String repoDir, PublicRepositoryI servant)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
omero.api.RawFileStorePrx	createRawFileStore(omero.model.OriginalFile file, Ice.Current __current)
omero.api.RawPixelsStorePrx	createRawPixelsStore(omero.model.OriginalFile file, Ice.Current __current)
omero.api.RenderingEnginePrx	createRenderingEngine(omero.model.OriginalFile file, Ice.Current __current)
omero.api.ThumbnailStorePrx	createThumbnailStore(omero.model.OriginalFile file, Ice.Current __current)
String	generateRepoUuid() Called when this repository is creating a new OriginalFile repository object.
Ice.Communicator	getCommunicator()
omero.model.OriginalFile	getDescription(Ice.Current __current)
protected omero.model.OriginalFileI	getDescription(long id)
abstract String	getFilePath(omero.model.OriginalFile file, Ice.Current __current)
protected String	getFileRepo(omero.model.OriginalFile file)
Ice.ObjectAdapter	getObjectAdapter()
omero.grid.RepositoryPrx	getProxy(Ice.Current __current)
String	getRepoUuid()
void	onApplicationEvent(InternalMessage im) Handle an application event.
omero.cmd.Response	rawAccess(omero.grid.RawAccessRequest req, Ice.Current __current)
boolean	takeover() Method called in a background thread which may end up waiting indefinitely on the repository lock file ("${omero.data.dir}/.omero/repository/${omero.db.uuid}/repo_uuid").

Methods inherited from class omero.grid._InternalRepositoryDisp

___createRawFileStore, ___createRawPixelsStore, ___createRenderingEngine, ___createThumbnailStore, ___getDescription, ___getFilePath, ___getProxy, ___rawAccess, __dispatch, __readImpl, __writeImpl, createRawFileStore, createRawPixelsStore, createRenderingEngine, createThumbnailStore, getDescription, getFilePath, getProxy, ice_copyStateFrom, ice_id, ice_id, ice_ids, ice_ids, ice_isA, ice_isA, ice_staticId, rawAccess

Methods inherited from class Ice.ObjectImpl

___ice_id, ___ice_ids, ___ice_isA, ___ice_ping, __checkMode, __collocDispatch, __read, __read, __readImpl, __write, __write, __writeImpl, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Methods inherited from class java.lang.Object

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

Methods inherited from interface Ice.Object

__collocDispatch, __read, __read, __write, __write, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Constructor Detail

AbstractRepositoryI

public AbstractRepositoryI(Ice.ObjectAdapter oa,
                   Registry reg,
                   Executor ex,
                   Principal p,
                   String repoDir,
                   PublicRepositoryI servant)

AbstractRepositoryI

public AbstractRepositoryI(Ice.ObjectAdapter oa,
                   Registry reg,
                   Executor ex,
                   Principal p,
                   FileMaker fileMaker,
                   PublicRepositoryI servant)

Method Detail

generateRepoUuid

public String generateRepoUuid()

Called when this repository is creating a new OriginalFile repository object.

onApplicationEvent

public void onApplicationEvent(InternalMessage im)

Description copied from interface: org.springframework.context.ApplicationListener

Handle an application event.

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<InternalMessage>

Parameters:

im - the event to respond to

takeover

public boolean takeover()

Method called in a background thread which may end up waiting indefinitely on the repository lock file ("${omero.data.dir}/.omero/repository/${omero.db.uuid}/repo_uuid").

close

public void close()

getRepoUuid

public final String getRepoUuid()

getCommunicator

public final Ice.Communicator getCommunicator()

getObjectAdapter

public final Ice.ObjectAdapter getObjectAdapter()

getDescription

public final omero.model.OriginalFile getDescription(Ice.Current __current)

Specified by:

getDescription in interface omero.grid._InternalRepositoryOperations

getProxy

public final omero.grid.RepositoryPrx getProxy(Ice.Current __current)

Specified by:

getProxy in interface omero.grid._InternalRepositoryOperations

rawAccess

public omero.cmd.Response rawAccess(omero.grid.RawAccessRequest req,
                           Ice.Current __current)
                             throws omero.ServerError

Specified by:

rawAccess in interface omero.grid._InternalRepositoryOperations

Throws:

omero.ServerError

getFilePath

public abstract String getFilePath(omero.model.OriginalFile file,
                 Ice.Current __current)
                            throws omero.ServerError

Specified by:

getFilePath in interface omero.grid._InternalRepositoryOperations

Throws:

omero.ServerError

createRawFileStore

public omero.api.RawFileStorePrx createRawFileStore(omero.model.OriginalFile file,
                                           Ice.Current __current)

Specified by:

createRawFileStore in interface omero.grid._InternalRepositoryOperations

createRawPixelsStore

public omero.api.RawPixelsStorePrx createRawPixelsStore(omero.model.OriginalFile file,
                                               Ice.Current __current)

Specified by:

createRawPixelsStore in interface omero.grid._InternalRepositoryOperations

createRenderingEngine

public omero.api.RenderingEnginePrx createRenderingEngine(omero.model.OriginalFile file,
                                                 Ice.Current __current)

Specified by:

createRenderingEngine in interface omero.grid._InternalRepositoryOperations

createThumbnailStore

public omero.api.ThumbnailStorePrx createThumbnailStore(omero.model.OriginalFile file,
                                               Ice.Current __current)

Specified by:

createThumbnailStore in interface omero.grid._InternalRepositoryOperations

getDescription

protected omero.model.OriginalFileI getDescription(long id)
                                            throws omero.ServerError

Throws:

omero.ServerError

getFileRepo

protected String getFileRepo(omero.model.OriginalFile file)
                      throws omero.ServerError

Throws:

omero.ServerError