code: @Override
  	protected final void wakeUp()
      {
      	// Note : Only called asynchronously by a wake up task after a notification packet has arrived
      	
      	// Check that the consumer is not closed
  		if (closed)
  			return;
      		
          // Check that the connection is started
          if (!session.getConnection().isStarted())
              return;
  	        
          if (messageListener != null)
          {
          	wakeUpMessageListener();
          }
          else
          	throw new IllegalStateException("Unexpected message availability notification");
      }
docs: /*
  (non-Javadoc)
  @see net.timewalker.ffmq4.common.session.AbstractMessageConsumer#wakeUp()