A C D E G I J N O R S T U

A

acquireTransactionLocks() - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

acquireTransactionLocks() - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

acquireTransactionLocks() - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

run method of old ode clustering implementation BPS-675 public void run() { _todo.enqueue(new CheckStaleNodes(System.currentTimeMillis() + _staleInterval)); __log.debug("CHECK STALE NODES started"); for (String nodeId : _knownNodes) { Long lastSeen = _lastHeartBeat.get(nodeId); if ((lastSeen == null || (System.currentTimeMillis() - lastSeen) > _staleInterval) && !_nodeId.equals(nodeId)) { recoverStaleNode(nodeId); } } }

C

cancelJob(String) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

D

DatabaseDelegate - Interface in org.apache.ode.scheduler.simple

Database abstraction; provides all database access for the simple scheduler.

DatabaseException - Exception in org.apache.ode.scheduler.simple

Exception class thrown by DatabaseDelegate implementations.

DatabaseException(String) - Constructor for exception org.apache.ode.scheduler.simple.DatabaseException

DatabaseException(Exception) - Constructor for exception org.apache.ode.scheduler.simple.DatabaseException

DatabaseException(String, Exception) - Constructor for exception org.apache.ode.scheduler.simple.DatabaseException

deleteAllJobs() - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

deleteAllJobs() - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

deleteJob(String, String) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

Delete a job from the database.

deleteJob(String, String) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

dequeueImmediate(String, long, int) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

"Dequeue" jobs from the database that are ready for immediate execution; this basically is a select/delete operation with constraints on the nodeId and scheduled time.

dequeueImmediate(String, long, int) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

E

execIsolatedTransaction(Callable<T>) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

execTransaction(Callable<T>) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

execTransaction(Callable<T>, int) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

G

getGlobalDAOConnFac() - Static method in class org.apache.ode.scheduler.simple.JdbcDelegate

getHeartbeat() - Method in class org.apache.ode.scheduler.simple.Node

getKnownNodes() - Method in interface org.apache.ode.scheduler.simple.ODECluster

getLeader() - Method in interface org.apache.ode.scheduler.simple.ODECluster

Retrieve leader node of the cluster

getLeaderNode() - Method in class org.apache.ode.scheduler.simple.Node

getNodeId() - Method in class org.apache.ode.scheduler.simple.Node

getNodeIds() - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

Return a list of unique nodes identifiers found in the database.

getNodeIds() - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

I

insertJob(Job, String, boolean) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

Save the job in the database.

insertJob(Job, String, boolean) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

insertNode(String, long, String) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

insertNode(String, long, String) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

isClusterEnabled() - Method in interface org.apache.ode.scheduler.simple.ODECluster

isLeader() - Method in interface org.apache.ode.scheduler.simple.ODECluster

isManager() - Method in interface org.apache.ode.scheduler.simple.ODECluster

Check whether this node is the Manager Node of the cluster

isTransacted() - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

J

JdbcDelegate - Class in org.apache.ode.scheduler.simple

JDBC-based implementation of the DatabaseDelegate interface.

JdbcDelegate(DataSource) - Constructor for class org.apache.ode.scheduler.simple.JdbcDelegate

JobNoLongerInDbException - Exception in org.apache.ode.scheduler.simple

Exception thrown if an attempt has been made to commit a job that is no longer in the database.

JobNoLongerInDbException(String, String) - Constructor for exception org.apache.ode.scheduler.simple.JobNoLongerInDbException

N

Node - Class in org.apache.ode.scheduler.simple

This class used to represent node in the cluster setup

Node(String, long, String) - Constructor for class org.apache.ode.scheduler.simple.Node

O

ODECluster - Interface in org.apache.ode.scheduler.simple

org.apache.ode.scheduler.simple - package org.apache.ode.scheduler.simple

R

registerSynchronizer(Scheduler.Synchronizer) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

removeMember(String) - Method in interface org.apache.ode.scheduler.simple.ODECluster

Remove member from the cluster

removeNode(String) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

removeNode(String) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

retrieveClusterNodes(String) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

retrieveClusterNodes(String) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

runJob(Job) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

Run a job in the current thread.

runPolledRunnable(Job) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

Run a job from a polled runnable thread.

runTask(Task) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

S

scheduleMapSerializableRunnable(Scheduler.MapSerializableRunnable, Date) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

schedulePersistedJob(Scheduler.JobDetails, Date) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

scheduleVolatileJob(boolean, Scheduler.JobDetails) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

scheduleVolatileJob(boolean, Scheduler.JobDetails, Date) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setCluster(ODECluster) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

Related to New ODE clustering implementation-BPS-675

setDatabaseDelegate(DatabaseDelegate) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setExecutorService(ExecutorService) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setGlobalDAOConnFac(BpelDAOConnectionFactory) - Static method in class org.apache.ode.scheduler.simple.JdbcDelegate

setImmediateInterval(long) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setJobProcessor(Scheduler.JobProcessor) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setNearFutureInterval(long) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setNodeId(String) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setPolledRunnableProcesser(Scheduler.JobProcessor) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setPollIntervalForPolledRunnable(long) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setRollbackOnly() - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setStaleInterval(long) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setTransactionManager(TransactionManager) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

setTransactionsPerSecond(int) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

shutdown() - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

SimpleScheduler - Class in org.apache.ode.scheduler.simple

A reliable and relatively simple scheduler that uses a database to persist information about scheduled tasks.

SimpleScheduler(String, DatabaseDelegate, Properties) - Constructor for class org.apache.ode.scheduler.simple.SimpleScheduler

start() - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

stop() - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

T

toString() - Method in class org.apache.ode.scheduler.simple.Node

U

updateAssignToNode(String, int, int, long) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

Assign a particular node identifier to a fraction of jobs in the database that do not have one, and are up for execution within a certain time.

updateAssignToNode(String, int, int, long) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

updateHeartBeat(String) - Method in class org.apache.ode.scheduler.simple.SimpleScheduler

Deprecated.

updateJob(Job) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

Update the job in the database (only updates timestamp and retryCount)

updateJob(Job) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

updateNodeHeartbeat(String, long, String) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

updateNodeHeartbeat(String, long, String) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

updateReassign(String, String) - Method in interface org.apache.ode.scheduler.simple.DatabaseDelegate

Reassign jobs from one node to another.

updateReassign(String, String) - Method in class org.apache.ode.scheduler.simple.JdbcDelegate

A C D E G I J N O R S T U