code: public void purge()
     {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "purge");
  
  	   synchronized(queueMonitor)
  	   {
  		   state = CLOSED;
  		   for (int i=0; i < JFapChannelConstants.MAX_PRIORITY_LEVELS-1; ++i)
  		   {
  			   queueArray[i].monitor.setActive(false);
  		   }
  		   closeWaitersMonitor.setActive(false);
  	   }
  
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "purge");
     }
docs: Purges the content of the priority queue.  This closes the queue and
  wakes up any blocked threads