private static synchronized int getRepeatedTimes()

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

• 13 lines of code
• 7 McCabe index (conditional complexity)

    private static synchronized int getRepeatedTimes(Collection<MessageExt> recvMsgs, MessageExt msg) {
        int count = 0;
        for (MessageExt recvMsg : recvMsgs) {
            if (recvMsg.getUserProperty("UNIQ_KEY") != null && !recvMsg.getUserProperty("UNIQ_KEY").equals(recvMsg.getMsgId()) && !recvMsg.getMsgId().equals(msg.getMsgId())) {
                if (recvMsg.getUserProperty("UNIQ_KEY").equals(msg.getMsgId())) {
                    count++;
                }
            } else if (recvMsg.getMsgId().equals(msg.getMsgId())) {
                count++;
            }
        }
        return count;
    }