code: @Override
  	protected final void onConsumerClose()
      {
      	super.onConsumerClose();
      	
      	// Unregister the consumer from the associated destination
      	unregister();
      	
      	try
      	{
      		engine.getDeliveryAsyncTaskManager().cancelTask(wakeUpAsyncTask);
      	}
      	catch (JMSException e)
      	{
      		ErrorTools.log(e, log);
      	}
      }
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.common.session.AbstractMessageConsumer#onConsumerClose()