Class TicketRepository

java.lang.Object

ecmwf.common.technical.ThreadService.ConfigurableRunnable

ecmwf.common.technical.WakeupThread

ecmwf.common.ecaccess.ECaccessScheduler

ecmwf.common.ecaccess.MBeanScheduler

ecmwf.common.ecaccess.MBeanRepository<AbstractTicket>

ecmwf.common.ecaccess.StorageRepository<AbstractTicket>

ecmwf.common.ecaccess.TicketRepository

All Implemented Interfaces:

MBeanService, MonitorCallback, Closeable, AutoCloseable, Runnable

public class TicketRepository
extends StorageRepository<AbstractTicket>

The Class TicketRepository.

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
TicketRepository(String name)	Instantiates a new ticket repository.

Method Summary

Modifier and Type	Method	Description
<E extends AbstractTicket> E	add(E ticket)	Adds the new ticket.
<E extends AbstractTicket> E	add(E ticket, long id)	Adds the new ticket.
AbstractTicket	check(long id, boolean wait)	Check.
AbstractTicket	check(long id, long wait)	Check.
boolean	expired(AbstractTicket ticket)	Expired.
AbstractTicket	get(long id)	Gets the.
<T extends AbstractTicket> T	get(long id, Class<T> clazz)	Gets the.
String	getKey(AbstractTicket ticket)	Gets the key.
String	getStatus(AbstractTicket ticket)	Gets the status.
long	getTimeOut()	Gets the time out.
long	getTimeOutAfterCompletion()	Gets the time out after completion.
AbstractTicket	remove(long id)	Removes the.
void	setTimeOut(long timeout)	Sets the time out.
void	setTimeOutAfterCompletion(long timeoutAfterCompletion)	Sets the time out after completion.
void	update(AbstractTicket ticket)	Update.

Methods inherited from class ecmwf.common.ecaccess.StorageRepository

getAttribute, getMBeanInfo, getThreadsSize, initialize, invoke, nextStep, shutdown, toString

Methods inherited from class ecmwf.common.ecaccess.MBeanRepository

clear, containsKey, containsValue, getComparator, getList, getList, getSize, 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

TicketRepository

public TicketRepository(String name)

Instantiates a new ticket repository.

Parameters:

name - the name

Method Details

add

public <E extends AbstractTicket> E add(E ticket)

Adds the new ticket.

Type Parameters:

E - the element type

Parameters:

ticket - the ticket

Returns:

the e

add

public <E extends AbstractTicket> E add(E ticket,
 long id)

Adds the new ticket.

Type Parameters:

E - the element type

Parameters:

ticket - the ticket

id - the id

Returns:

the e

getTimeOut

public long getTimeOut()

Gets the time out.

Returns:

the time out

setTimeOut

public void setTimeOut(long timeout)

Sets the time out.

Parameters:

timeout - the new time out

getTimeOutAfterCompletion

public long getTimeOutAfterCompletion()

Gets the time out after completion.

Returns:

the time out after completion

setTimeOutAfterCompletion

public void setTimeOutAfterCompletion(long timeoutAfterCompletion)

Sets the time out after completion.

Parameters:

timeoutAfterCompletion - the new time out after completion

get

public AbstractTicket get(long id)

Gets the.

Parameters:

id - the id

Returns:

the abstract ticket

get

public <T extends AbstractTicket> T get(long id,
 Class<T> clazz)

Gets the.

Type Parameters:

T - the generic type

Parameters:

id - the id

clazz - the clazz

Returns:

the abstract ticket

check

public AbstractTicket check(long id,
 long wait)
                     throws IOException

Check.

Parameters:

id - the id

wait - the wait

Returns:

the abstract ticket

Throws:

IOException - Signals that an I/O exception has occurred.

check

public AbstractTicket check(long id,
 boolean wait)
                     throws IOException

Check.

Parameters:

id - the id

wait - the wait

Returns:

the abstract ticket

Throws:

IOException - Signals that an I/O exception has occurred.

remove

public AbstractTicket remove(long id)

Removes the.

Parameters:

id - the id

Returns:

the abstract ticket

getKey

public String getKey(AbstractTicket ticket)

Gets the key. Gets the key.

Overrides:

getKey in class MBeanRepository<AbstractTicket>

Parameters:

ticket - the object

Returns:

the key

getStatus

public String getStatus(AbstractTicket ticket)

Gets the status. Gets the status.

Overrides:

getStatus in class MBeanRepository<AbstractTicket>

Parameters:

ticket - the object

Returns:

the status

expired

public boolean expired(AbstractTicket ticket)

Expired. Expired.

Overrides:

expired in class StorageRepository<AbstractTicket>

Parameters:

ticket - the object

Returns:

true, if successful

update

public void update(AbstractTicket ticket)

Update. Update.

Specified by:

update in class StorageRepository<AbstractTicket>

Parameters:

ticket - the object