docs: private MessageConsumer createMessageConsumer(Destination replyToDestination, String messageId) throws JMSException {
          MessageConsumer messageConsumer;
  
          if (replyToDestination instanceof Queue) {
              messageConsumer = session.createConsumer(replyToDestination,
                      "JMSCorrelationID = '" + messageId.replaceAll("'", "''") + "'");
          } else {
              messageConsumer = session.createDurableSubscriber((Topic)replyToDestination, getName(),
                      "JMSCorrelationID = '" + messageId.replaceAll("'", "''") + "'", false);
          }
  
          return messageConsumer;
      }