[richfaces-issues] [JBoss JIRA] (RF-12219) Push: Test that messages do not become stale in a queue

[ https://issues.jboss.org/browse/RF-12219?page=com.atlassian.jira.plugin.s... ] Milo van der Zee edited comment on RF-12219 at 5/14/12 7:30 AM: ---------------------------------------------------------------- {{ /** * Send push events to configured topics. */ public class PushTriggerJob implements BatchJobInterface { private static final Logger LOGGER = Logger.getLogger(PushTriggerJob.class); @Override public void executeBatch(BatchJobContext context) { String[] pushKeys = context.getParameters().trim().split(","); TopicsContext topicsContext = TopicsContext.lookup(); boolean first = true; for (String pushKey : pushKeys) { if (!first) { // delay 1 second for all except the first one Utils.sleep(1000); } first = false; try { LOGGER.debug("triggerPush: pushing '" + pushKey + "' topicsContext: " + topicsContext); topicsContext.publish(new TopicKey(pushKey), null); } catch (MessageException e) { LOGGER.error("executeBatch, topicsContext: " + topicsContext, e); } } } } }} was (Author: MilovdZee): {{monospaced}} /** * Send push events to configured topics. */ public class PushTriggerJob implements BatchJobInterface { private static final Logger LOGGER = Logger.getLogger(PushTriggerJob.class); @Override public void executeBatch(BatchJobContext context) { String[] pushKeys = context.getParameters().trim().split(","); TopicsContext topicsContext = TopicsContext.lookup(); boolean first = true; for (String pushKey : pushKeys) { if (!first) { // delay 1 second for all except the first one Utils.sleep(1000); } first = false; try { LOGGER.debug("triggerPush: pushing '" + pushKey + "' topicsContext: " + topicsContext); topicsContext.publish(new TopicKey(pushKey), null); } catch (MessageException e) { LOGGER.error("executeBatch, topicsContext: " + topicsContext, e); } } } } {{monospaced}} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira