code: public Message getNext( String name ) {
      synchronized( _queue ) {
        for (int idx = 0; idx < _queue.size(); idx++) {
          Message m = (Message)_queue.get(idx);
          if (m.headers().get( "destination" ).equals(name)) {
            _queue.remove(idx);
            return m;
          }
        }
      }
      return null;
    }
docs: Get the next unconsumed message for a particular channel.   This is
  non-blocking.
  
  @param name the name of the channel to search for
  
  @return the next message for the channel, or null if the queue
  contains no messages for the channel.