Azure Service Bus - error for topic subscriber

[mariuszbozek]

Hi,

I have problem with accessing to Azure Service Bus Topic.
I'm using an extension (Quarkus version 2.16.0.Final)

<dependency>
    <groupId>org.amqphub.quarkus</groupId>
    <artifactId>quarkus-qpid-jms</artifactId>
</dependency>

    @Override
    public void run() {
        try {
            TopicConnection connection = connectionFactory.createTopicConnection(connectionStringProperties.getSharedAccessKeyName(), connectionStringProperties.getSharedAccessKey());
            connection.setClientID(UUID.randomUUID().toString());
            connection.start();
            TopicSession session = connection.createTopicSession(false, Session.CLIENT_ACKNOWLEDGE);
            TopicSubscriber subscriber = session.createDurableSubscriber(session.createTopic("topic.demo"), "sub1");
            while (true) {
                Message message = subscriber.receive();
                if (message == null) return;
                var payload = message.getBody(String.class);
                LOGGER.info("Received: {}", payload);
            }
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

I received the error:
It is not possible for an entity that requires sessions to create a non-sessionful message receiver

The topic on Azure Service Bus has enabled the option 'Requires Session' (I can't change it)