org.jboss.messaging.util
Class ClearableQueuedExecutor

java.lang.Object
  QueuedExecutor
      org.jboss.messaging.util.ClearableQueuedExecutor

public class ClearableQueuedExecutor
extends QueuedExecutor

A ClearableQueuedExecutor This class extends the QueuedExector with a method to clear all but the currently executing task without shutting it down. We need this functionality when failing over a session. In that case we need to clear all tasks apart from the currently executing one. We can't just shutdownAfterProcessingCurrentTask then use another instance after failover since when failover resumes the current task and the next delivery will be executed on different threads and smack into each other. http://jira.jboss.org/jira/browse/JBMESSAGING-904

Version:

$Revision: 1.1 $ $Id$

Author:

Tim Fox

Constructor Summary

ClearableQueuedExecutor()

ClearableQueuedExecutor(Channel channel)

Method Summary

void	clearAllExceptCurrentTask()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClearableQueuedExecutor

public ClearableQueuedExecutor()

ClearableQueuedExecutor

public ClearableQueuedExecutor(Channel channel)

Method Detail

clearAllExceptCurrentTask

public void clearAllExceptCurrentTask()