ome.services.blitz.fire

Class Registry.Impl

java.lang.Object

ome.services.blitz.fire.Registry.Impl

All Implemented Interfaces:

Registry

Enclosing interface:

Registry

public static class Registry.Impl
extends Object
implements Registry

Nested Class Summary

Nested classes/interfaces inherited from interface ome.services.blitz.fire.Registry

Registry.Impl

Constructor Summary

Constructors

Constructor and Description
Impl(Ice.Communicator ic)

Method Summary

Modifier and Type	Method and Description
void	addObject(Ice.ObjectPrx obj)
IceGrid.AdminSessionPrx	getAdminSession() Create a new AdminSessionPrx with the RegistryPrx.
IceGrid.QueryPrx	getGridQuery() Returns an active QueryPrx or null if none is available.
omero.api.ServiceFactoryPrx	getInternalServiceFactory(String user, String group, int retries, int interval, String client_uuid) Try to return a ServiceFactory from the grid.
omero.grid.ClusterNodePrx[]	lookupClusterNodes() Returns all found cluster nodes or null if something goes wrong during lookup (null QueryPrx for example)
omero.grid.monitors.MonitorServerPrx[]	lookupMonitorServers()
omero.grid.ProcessorPrx[]	lookupProcessors()
omero.grid.InternalRepositoryPrx[]	lookupRepositories()
omero.grid.TablesPrx[]	lookupTables()
void	removeObject(Ice.Identity id)
boolean	removeObjectSafely(Ice.Identity id)

Methods inherited from class java.lang.Object

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

Constructor Detail

Impl

public Impl(Ice.Communicator ic)

Method Detail

getInternalServiceFactory

public omero.api.ServiceFactoryPrx getInternalServiceFactory(String user,
                                                             String group,
                                                             int retries,
                                                             int interval,
                                                             String client_uuid)
                                                      throws Exception

Description copied from interface: Registry

Try to return a ServiceFactory from the grid. Try a number of times then give up and raise the last exception returned. This method will only work internally to the grid, i.e. behind the Glacier2 firewall. It is intended for internal servers to be able to create sessions for accessing the database.

 communicator := Ice.Communicator used to find the registry
 user         := Username which should have a session created
 group        := Group into which the session should be logged
 retries      := Number of session creation retries before throwing
 interval     := Seconds between retries
 client_uuid  := Uuid of the client which should be used
 

Specified by:

getInternalServiceFactory in interface Registry

Throws:

Exception

getGridQuery

public IceGrid.QueryPrx getGridQuery()

Description copied from interface: Registry

Returns an active QueryPrx or null if none is available.

Specified by:

getGridQuery in interface Registry

getAdminSession

public IceGrid.AdminSessionPrx getAdminSession()
                                        throws IceGrid.PermissionDeniedException

Description copied from interface: Registry

Create a new AdminSessionPrx with the RegistryPrx. Consumers are required to properly SessionPrx.destroy() the returned session.

Specified by:

getAdminSession in interface Registry

Returns:

See above.

Throws:

IceGrid.PermissionDeniedException

addObject

public void addObject(Ice.ObjectPrx obj)
               throws Exception

Specified by:

addObject in interface Registry

Throws:

Exception

removeObject

public void removeObject(Ice.Identity id)
                  throws Exception

Specified by:

removeObject in interface Registry

Throws:

Exception

removeObjectSafely

public boolean removeObjectSafely(Ice.Identity id)

Specified by:

removeObjectSafely in interface Registry

lookupClusterNodes

public omero.grid.ClusterNodePrx[] lookupClusterNodes()

Description copied from interface: Registry

Returns all found cluster nodes or null if something goes wrong during lookup (null QueryPrx for example)

Specified by:

lookupClusterNodes in interface Registry

lookupProcessors

public omero.grid.ProcessorPrx[] lookupProcessors()

Specified by:

lookupProcessors in interface Registry

lookupTables

public omero.grid.TablesPrx[] lookupTables()

Specified by:

lookupTables in interface Registry

lookupRepositories

public omero.grid.InternalRepositoryPrx[] lookupRepositories()

Specified by:

lookupRepositories in interface Registry

lookupMonitorServers

public omero.grid.monitors.MonitorServerPrx[] lookupMonitorServers()

Specified by:

lookupMonitorServers in interface Registry