com.wm.app.tn.db
Class QueueOperations

java.lang.Object
  com.wm.app.tn.db.QueueOperations

public class QueueOperations
extends java.lang.Object

Provides database operations for maintaining DeliveryQueues.

Constructor Summary

QueueOperations()

Method Summary

static boolean	delete(java.sql.Connection conn, java.lang.String queueName)
static boolean	delete(java.lang.String queueName)
static GuaranteedJob	dequeueOldestJob(java.lang.String queue)
static java.util.Vector	dequeueOldestJobs(java.lang.String queue, int jobCount)
static java.lang.String[]	getDependentJobs(java.lang.String queue)
static java.lang.String[]	getDependentProfiles(java.lang.String queue)
static java.lang.String	getPartnerQueue(java.lang.String partnerID)
static java.lang.String[]	getQueuedJobs(java.lang.String queue)
static boolean	insert(java.sql.Connection conn, DeliveryQueue q)
static boolean	insert(DeliveryQueue q)
static DeliveryQueue[]	queryByName(java.sql.Connection conn, java.lang.String name)
static DeliveryQueue[]	queryByName(java.lang.String name)
static void	resetDeliveringStatus()
static DeliveryQueue[]	select(java.sql.Connection conn, java.lang.String type)
static DeliveryQueue[]	select(java.lang.String type)
static DeliveryQueue	selectByName(java.sql.Connection conn, java.lang.String name)
static DeliveryQueue	selectByName(java.lang.String name)
static boolean	update(java.sql.Connection conn, DeliveryQueue q)
static boolean	update(DeliveryQueue q)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueOperations

public QueueOperations()

Method Detail

insert

public static boolean insert(DeliveryQueue q)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

insert

public static boolean insert(java.sql.Connection conn,
                             DeliveryQueue q)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

update

public static boolean update(DeliveryQueue q)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

update

public static boolean update(java.sql.Connection conn,
                             DeliveryQueue q)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

delete

public static boolean delete(java.lang.String queueName)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

delete

public static boolean delete(java.sql.Connection conn,
                             java.lang.String queueName)
                      throws java.sql.SQLException,
                             java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

select

public static DeliveryQueue[] select(java.lang.String type)
                              throws java.sql.SQLException,
                                     java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

select

public static DeliveryQueue[] select(java.sql.Connection conn,
                                     java.lang.String type)
                              throws java.sql.SQLException,
                                     java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

selectByName

public static DeliveryQueue selectByName(java.lang.String name)
                                  throws java.sql.SQLException,
                                         java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

selectByName

public static DeliveryQueue selectByName(java.sql.Connection conn,
                                         java.lang.String name)
                                  throws java.sql.SQLException,
                                         java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

queryByName

public static DeliveryQueue[] queryByName(java.lang.String name)
                                   throws java.sql.SQLException,
                                          java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

queryByName

public static DeliveryQueue[] queryByName(java.sql.Connection conn,
                                          java.lang.String name)
                                   throws java.sql.SQLException,
                                          java.io.IOException

Throws:

java.sql.SQLException

java.io.IOException

dequeueOldestJob

public static GuaranteedJob dequeueOldestJob(java.lang.String queue)
                                      throws DatastoreException,
                                             java.sql.SQLException

Throws:

DatastoreException

java.sql.SQLException

dequeueOldestJobs

public static java.util.Vector dequeueOldestJobs(java.lang.String queue,
                                                 int jobCount)
                                          throws DatastoreException,
                                                 java.sql.SQLException

Throws:

DatastoreException

java.sql.SQLException

resetDeliveringStatus

public static void resetDeliveringStatus()
                                  throws java.sql.SQLException

Throws:

java.sql.SQLException

getDependentJobs

public static java.lang.String[] getDependentJobs(java.lang.String queue)
                                           throws java.sql.SQLException

Throws:

java.sql.SQLException

getDependentProfiles

public static java.lang.String[] getDependentProfiles(java.lang.String queue)
                                               throws java.sql.SQLException

Throws:

java.sql.SQLException

getPartnerQueue

public static java.lang.String getPartnerQueue(java.lang.String partnerID)
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

getQueuedJobs

public static java.lang.String[] getQueuedJobs(java.lang.String queue)
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException