com.wm.app.tn.delivery
Class QueuingUtils

java.lang.Object
  com.wm.app.tn.delivery.QueuingUtils

public class QueuingUtils
extends java.lang.Object

Provides utility methods for batch document delivery. Used by wm.tn.queuing services.

Field Summary

static int	OP_ADD
static int	OP_CANCEL
static int	OP_RESUME
static int	OP_SUSPEND
static int	OP_UPDATE

Constructor Summary

QueuingUtils()

Method Summary

static void	addActivityEntry(int type, BizDocEnvelope doc, java.lang.String brief, java.lang.String full)
static boolean	alreadyInitialized()
static ActivityLogEntry	createActivityEntry(int type, java.lang.String partnerID, java.lang.String docID, java.lang.String brief, java.lang.String full)
static void	enqueueDocument(BizDocEnvelope doc, java.lang.String qName)
static com.wm.data.IData	getQueueDependencyMsg(java.lang.String queue)
static void	logDeliveryFailure(BizDocEnvelope doc, GuaranteedJob job, java.lang.String msg)
static boolean	scheduled(java.lang.String qName)
static void	scheduleDelivery(DeliveryQueue queue, int op)
static boolean	timeHasPassed(DeliverySchedule sched)
static void	updateQueueSched(com.wm.data.IData input)
static void	updateStatus(GuaranteedJob job, boolean success)
static void	validateSchedule(DeliveryQueue queue)

Methods inherited from class java.lang.Object

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

Field Detail

OP_ADD

public static final int OP_ADD

See Also:

Constant Field Values

OP_UPDATE

public static final int OP_UPDATE

See Also:

Constant Field Values

OP_CANCEL

public static final int OP_CANCEL

See Also:

Constant Field Values

OP_SUSPEND

public static final int OP_SUSPEND

See Also:

Constant Field Values

OP_RESUME

public static final int OP_RESUME

See Also:

Constant Field Values

Constructor Detail

QueuingUtils

public QueuingUtils()

Method Detail

scheduleDelivery

public static void scheduleDelivery(DeliveryQueue queue,
                                    int op)
                             throws java.lang.Exception

Throws:

java.lang.Exception

scheduled

public static boolean scheduled(java.lang.String qName)

updateQueueSched

public static void updateQueueSched(com.wm.data.IData input)

getQueueDependencyMsg

public static com.wm.data.IData getQueueDependencyMsg(java.lang.String queue)
                                               throws java.sql.SQLException,
                                                      java.io.IOException,
                                                      ProfileStoreException

Throws:

java.sql.SQLException

java.io.IOException

ProfileStoreException

enqueueDocument

public static void enqueueDocument(BizDocEnvelope doc,
                                   java.lang.String qName)
                            throws java.lang.Exception

Throws:

java.lang.Exception

logDeliveryFailure

public static void logDeliveryFailure(BizDocEnvelope doc,
                                      GuaranteedJob job,
                                      java.lang.String msg)

updateStatus

public static void updateStatus(GuaranteedJob job,
                                boolean success)
                         throws java.lang.Exception

Throws:

java.lang.Exception

addActivityEntry

public static void addActivityEntry(int type,
                                    BizDocEnvelope doc,
                                    java.lang.String brief,
                                    java.lang.String full)

createActivityEntry

public static ActivityLogEntry createActivityEntry(int type,
                                                   java.lang.String partnerID,
                                                   java.lang.String docID,
                                                   java.lang.String brief,
                                                   java.lang.String full)

validateSchedule

public static void validateSchedule(DeliveryQueue queue)
                             throws DeliveryException

Throws:

DeliveryException

timeHasPassed

public static boolean timeHasPassed(DeliverySchedule sched)
                             throws DeliveryException

Throws:

DeliveryException

alreadyInitialized

public static boolean alreadyInitialized()