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