{
{  if (connectionType == TYPE_QUEUE_CONNECTION) throw new IllegalStateException("Cannot create a durable connection consumer on a QueueConnection");
   public ConnectionConsumer createDurableConnectionConsumer(         Topic topic,         String subscriptionName,         String messageSelector,         ServerSessionPool sessionPool,         int maxMessages)         throws JMSException   {      throw new NotYetImplementedException();   }