Class StorageRepository<O>

java.lang.Object

ecmwf.common.technical.ThreadService.ConfigurableRunnable

ecmwf.common.technical.WakeupThread

ecmwf.common.ecaccess.ECaccessScheduler

ecmwf.common.ecaccess.MBeanScheduler

ecmwf.common.ecaccess.MBeanRepository<O>

ecmwf.common.ecaccess.StorageRepository<O>

Type Parameters:

O - the generic type

All Implemented Interfaces:

MBeanService, MonitorCallback, Closeable, AutoCloseable, Runnable

Direct Known Subclasses:

ECaccessProvider.ProviderMBean, TicketRepository

public abstract class StorageRepository<O>
extends MBeanRepository<O>

The Class StorageRepository.

Field Summary

Fields inherited from class ecmwf.common.ecaccess.ECaccessScheduler

NEXT_STEP_ABORT, NEXT_STEP_CONTINUE, NEXT_STEP_DELAY, NEXT_STEP_INIT, SCHEDULER_STATE_CLOSING, SCHEDULER_STATE_JAMMED, SCHEDULER_STATE_OFFLINE, SCHEDULER_STATE_ONHOLD, SCHEDULER_STATE_ONLINE, SCHEDULER_STATE_OPENING, states, steps

Constructor Summary

Constructors

Constructor	Description
StorageRepository(String name, int storageThreadsCount, long storageThreadsDelay)	Instantiates a new storage repository.

Method Summary

Modifier and Type	Method	Description
boolean	expired(O object)	Expired.
Object	getAttribute(String attributeName)	Gets the attribute.
MBeanInfo	getMBeanInfo()	Gets the MBean info.
int	getThreadsSize()	Gets the threads list size.
void	initialize()	Initialize.
Object	invoke(String operationName, Object[] params, String[] signature)	Invoke.
int	nextStep()	Next step.
void	shutdown()	Shutdown.
String	toString()	To string.
abstract void	update(O object)	Update.

Methods inherited from class ecmwf.common.ecaccess.MBeanRepository

clear, containsKey, containsValue, getComparator, getKey, getList, getList, getSize, getStatus, getStatus, getValue, getWakeup, put, removeKey, removeValue, setComparator, setMaxAuthorisedSize, setWakeup, sort

Methods inherited from class ecmwf.common.ecaccess.MBeanScheduler

close, getMonitorName, setAttribute

Methods inherited from class ecmwf.common.ecaccess.ECaccessScheduler

configurableRun, deactivateMonitor, getActivity, getDelay, getJammedTimeout, getLastStepTime, getMonitorManager, getNextStep, getSchedulerState, getStartDate, getStepTime, isInitialized, isJammed, isOnHold, isRunning, onHold, setDelay, setJammedTimeout, setOnhold, setTimeRanges, start, wakeup

Methods inherited from class ecmwf.common.technical.WakeupThread

isSleeping, waitFor

Methods inherited from class ecmwf.common.technical.ThreadService.ConfigurableRunnable

execute, execute, getContextClassLoader, getPriority, getThreadName, interrupt, interrupted, isAlive, isStarted, join, join, run, setContextClassLoader, setForceCookie, setInheritCookie, setPriority, setThreadNameAndCookie

Methods inherited from class java.lang.Object

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

Constructor Details

StorageRepository

public StorageRepository(String name,
 int storageThreadsCount,
 long storageThreadsDelay)

Instantiates a new storage repository.

Parameters:

name - the name

storageThreadsCount - the storage threads count

storageThreadsDelay - the storage threads delay

Method Details

expired

public boolean expired(O object)

Expired.

Parameters:

object - the object

Returns:

true, if successful

update

public abstract void update(O object)
                     throws Exception

Update.

Parameters:

object - the object

Throws:

Exception - the exception

initialize

public void initialize()

Initialize. Initialize.

Overrides:

initialize in class ECaccessScheduler

getThreadsSize

public int getThreadsSize()

Gets the threads list size.

Returns:

the size

shutdown

public void shutdown()

Shutdown. Shutdown. Shutdown.

Overrides:

shutdown in class MBeanScheduler

nextStep

public int nextStep()

Next step. Next step.

Specified by:

nextStep in class ECaccessScheduler

Returns:

the int

getMBeanInfo

public MBeanInfo getMBeanInfo()

Gets the MBean info. Gets the MBean info. Gets the MBean info. Gets the MBean info.

Specified by:

getMBeanInfo in interface MBeanService

Overrides:

getMBeanInfo in class MBeanRepository<O>

Returns:

the MBean info

getAttribute

public Object getAttribute(String attributeName)
                    throws AttributeNotFoundException,
MBeanException

Gets the attribute. Gets the attribute. Gets the attribute. Gets the attribute.

Specified by:

getAttribute in interface MBeanService

Overrides:

getAttribute in class MBeanRepository<O>

Parameters:

attributeName - the attribute name

Returns:

the attribute

Throws:

AttributeNotFoundException - the attribute not found exception

MBeanException - the MBean exception

invoke

public Object invoke(String operationName,
 Object[] params,
 String[] signature)
              throws NoSuchMethodException,
MBeanException

Invoke. Invoke. Invoke. Invoke.

Specified by:

invoke in interface MBeanService

Overrides:

invoke in class MBeanRepository<O>

Parameters:

operationName - the operation name

params - the params

signature - the signature

Returns:

the object

Throws:

NoSuchMethodException - the no such method exception

MBeanException - the MBean exception

toString

public String toString()

To string.

Overrides:

toString in class Object