需要会话的实体不可能创建非会话消息接收器

Question

听众

@JmsListener(destination = "${servicebus.entities.acsTopicToListen.entityName}", containerFactory = "topicJmsListenerContainerFactory", subscription = "${servicebus.entities.acsTopicToListen.subscriptionName}")
    public void run(byte[] message, Session session) throws Exception {

        try {
            acsDataHandler.messageProcessor(new String(message));
        } catch (Exception ex) {
            LOGGER.error("Exception thrown while listening to acsDataTopic...." + ex.getMessage());
            exceptionHelper.handleTransformError(INTERNAL_SERVER_ERROR, "Error from AcsDataReceiver listen()",
                    ACS0001.name(), ex);
        }

配置

    @Bean
    public ConnectionFactory schedulerConnectionFactory(ServicebusConnectionProperties serviceBusJMSProperties) {
        final String connectionString = serviceBusJMSProperties.getConnectionString();
        final String clientId = serviceBusJMSProperties.getTopiClientId();
        final int idleTimeout = serviceBusJMSProperties.getIdleTimeout();

        final ServiceBusKey serviceBusKey = ConnectionStringResolver.getServiceBusKey(connectionString);
        final String host = serviceBusKey.getHost();
        final String sasKeyName = serviceBusKey.getSharedAccessKeyName();
        final String sasKey = serviceBusKey.getSharedAccessKey();

        final String remoteUri = String.format(AMQP_URI_FORMAT, host, idleTimeout);
        final JmsConnectionFactory jmsConnectionFactory = new JmsConnectionFactory();
        jmsConnectionFactory.setRemoteURI(remoteUri);
        jmsConnectionFactory.setClientID(clientId);
        jmsConnectionFactory.setUsername(sasKeyName);
        jmsConnectionFactory.setPassword(sasKey);
        return new CachingConnectionFactory(jmsConnectionFactory);
    }

    @Bean
    public Destination destination() {
        return new JmsTopic(destination);
    }

    @Bean
    public JmsTemplate jmsTemplate(ConnectionFactory jmsConnectionFactory, Destination destination) {
        final JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(jmsConnectionFactory);
        jmsTemplate.setMessageIdEnabled(true);
        jmsTemplate.setDefaultDestination(destination);
        return jmsTemplate;
    }
    

    @Bean
    public JmsListenerContainerFactory<?> topicJmsListenerContainerFactory(ConnectionFactory connectionFactory) {
        final DefaultJmsListenerContainerFactory jmsListenerContainerFactory = new DefaultJmsListenerContainerFactory();
        jmsListenerContainerFactory.setConnectionFactory(connectionFactory);
        jmsListenerContainerFactory.setSubscriptionDurable(Boolean.TRUE);
        jmsListenerContainerFactory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        return jmsListenerContainerFactory;
    }

我正在使用 Azure Service Bus Spring Boot Starter 连接已启用会话的 Servicebus 主题/订阅，但无法连接以下消息： 需要会话的实体不可能创建非会话消息接收者。

Answer 1

在 Java 中，会话支持与 azure-servicebus 库示例一起使用 QueuesGettingStarted.java 通过将 queueClient.registerMessageHandler 更改为 queueClient.registerSessionHandler 并进行相关更改。

但在这种情况下，请检查： https://github.com/Azure/azure-service-bus/issues/326#issuecomment-573236250

https://github.com/MicrosoftDocs/azure-dev-docs/issues/285#issuecomment-699573311