private static boolean checkOrder()

in java/e2e-v4/src/main/java/org/apache/rocketmq/utils/VerifyUtils.java [338:354]

• 17 lines of code
• 3 McCabe index (conditional complexity)

    private static boolean checkOrder(DataCollector<MessageExt> dequeueMessages) {
        Collection<MessageExt> receivedMessages = dequeueMessages.getAllData();
        ConcurrentHashMap<String, LinkedList<MessageExt>> map = new ConcurrentHashMap<>();
        for (MessageExt receivedMessage : receivedMessages) {
            String shardingKey = String.valueOf(receivedMessage.getQueueId());
            LinkedList<MessageExt> messages;
            if (map.containsKey(shardingKey)) {
                messages = map.get(shardingKey);
                messages.add(receivedMessage);
            } else {
                messages = new LinkedList<>();
                messages.add(receivedMessage);
                map.put(shardingKey, messages);
            }
        }
        return checkOrderMessage(map);
    }