code: @Override
  	public synchronized ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool, int maxMessages) throws JMSException
      {
          checkNotClosed();
          throw new FFMQException("Unsupported feature","UNSUPPORTED_FEATURE");
      }
docs: /*
  (non-Javadoc)
  @see javax.jms.QueueConnection#createConnectionConsumer(javax.jms.Queue, java.lang.String, javax.jms.ServerSessionPool, int)