docs: protected void createSession(Connection connection) throws JMSException {
          if (session == null) {
              if (!endpointConfiguration.isPubSubDomain() && connection instanceof QueueConnection) {
                  session = ((QueueConnection) connection).createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
              } else if (endpointConfiguration.isPubSubDomain() && endpointConfiguration.getConnectionFactory() instanceof TopicConnectionFactory) {
                  session = ((TopicConnection) connection).createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
              } else {
                  log.warn("Not able to create a session with connection factory '" + endpointConfiguration.getConnectionFactory() + "'" +
                          " when using setting 'publish-subscribe-domain' (=" + endpointConfiguration.isPubSubDomain() + ")");
  
                  session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
              }
          }
      }