Azure服务总线IQueueClient。registerSessionHandler:无法连续使用来自队列/主题的消息

Question

要求：我需要从队列中获取所有会话中的所有消息registerSessionHandler应该在消息出现在队列中时立即使用它们。

问题：代码接受与会话id（xyz）之一相关的消息，然后等待。即使使用该会话id（xyz）推送更多消息，它也无法使用它。

任何建议-我在这里错过了什么明显的东西。

我有registerSessionHandler，用于从队列连续接收会话消息。每当我开始新会话时，我只收到一个sessionID的消息。

测试队列：在这个队列中，有20条消息可用，有4个不同的会话ID。每当我运行Java应用程序（QueueSessionReceiveTest.java）时，我只得到5条与单个会话ID相关的消息。

MAVEN-azure服务总线-1.1.1

接收代码：

import java.time.Duration;
import com.microsoft.azure.servicebus.IMessage;
import com.microsoft.azure.servicebus.IQueueClient;
import com.microsoft.azure.servicebus.QueueClient;
import com.microsoft.azure.servicebus.ReceiveMode;
import com.microsoft.azure.servicebus.SessionHandlerOptions;
import com.microsoft.azure.servicebus.primitives.ConnectionStringBuilder;
public class QueueSessionReceiveTest {
    private static final String connectionString = "Endpoint=sb://XXXXXX";
    private static final String queueName = "test";
    private static IQueueClient queueClient;
    public static void main(String[] args) throws Exception {
        queueClient = new QueueClient(new ConnectionStringBuilder(connectionString, queueName), ReceiveMode.PEEKLOCK);
        queueClient.registerSessionHandler(new QueueMessageSessionHandler(), new SessionHandlerOptions(1, false, Duration.ofMinutes(1)));           
        }}

会话处理程序代码：

import java.util.concurrent.CompletableFuture;
import com.microsoft.azure.servicebus.ExceptionPhase;
import com.microsoft.azure.servicebus.IMessage;
import com.microsoft.azure.servicebus.IMessageSession;
import com.microsoft.azure.servicebus.IQueueClient;
import com.microsoft.azure.servicebus.ISessionHandler;
public class QueueMessageSessionHandler implements ISessionHandler {
    @Override
    public CompletableFuture<Void> onMessageAsync(IMessageSession session, IMessage iMessage) {
        return session.completeAsync(iMessage.getLockToken()).thenRunAsync(() -> Logger.debug("some log") );
    }
    @Override
    public CompletableFuture<Void> OnCloseSessionAsync(IMessageSession session) {
        return null;
    }
    @Override
    public void notifyException(Throwable exception, ExceptionPhase exceptionPhase) {
        // Do nothing
    }}

Answer 1

请参考下面的链接了解解决方案。

https://github.com/Azure/azure-service-bus-java/issues/187