To create a queue you can use the following java code.
public static ScheduleQueue createScheduleQueueIfNecessary(String queueName) throws WTException {
ScheduleQueue sq = (ScheduleQueue) QueueHelper.manager.getQueue(queueName, ScheduleQueue.class);
logger.debug("ScheduledQueue '" + queueName + "' exists? sq=" + sq);
//create queue itself if necessary
if (sq == null) {
sq = QueueHelper.manager.createScheduleQueue(queueName);
logger.debug("created ScheduledQueue '" + queueName + "': sq=" + sq);
}
return sq;
}
And to create an entry in this queue the following method can be used
public static void addNewScheduleQueueEntry(ScheduleQueue sq, String className, String methodName, Timestamp nextTime, String message) throws WTException {
//Adding an entry
Class[] argTypes = {String.class};
Object[] args = {message};
WTPrincipal administrator = SessionHelper.manager.getAdministrator();
WTPrincipal previous = SessionContext.setEffectivePrincipal(administrator);
try {
sq.addEntry(administrator, methodName, className, argTypes, args, nextTime);
logger.debug("added new queueEntry to call '" + className + "." + methodName + "' nextScheduledTime=" + nextTime);
} finally {
SessionContext.setEffectivePrincipal(previous);
}
}
