public void resetOffset()

in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java [62:81]

• 20 lines of code
• 9 McCabe index (conditional complexity)

    public void resetOffset(RecordPartition recordPartition, RecordOffset recordOffset) {
        if (null == recordPartition || null == recordPartition.getPartition() || null == recordOffset || null == recordOffset.getOffset()) {
            logger.warn("recordPartition {} info is null or recordOffset {} info is null", recordPartition, recordOffset);
            return;
        }
        String brokerName = (String) recordPartition.getPartition().get(BROKER_NAME);
        String topic = (String) recordPartition.getPartition().get(TOPIC);
        Integer queueId = Integer.valueOf((String) recordPartition.getPartition().get(QUEUE_ID));
        if (StringUtils.isEmpty(brokerName) || StringUtils.isEmpty(topic) || null == queueId) {
            logger.warn("brokerName is null or queueId is null or queueName is null, brokerName {}, queueId {} queueId {}", brokerName, queueId, topic);
            return;
        }
        MessageQueue messageQueue = new MessageQueue(topic, brokerName, queueId);
        Long offset = Long.valueOf((String) recordOffset.getOffset().get(QUEUE_OFFSET));
        if (null == offset) {
            logger.warn("resetOffset, offset is null");
            return;
        }
        messageQueuesOffsetMap.put(messageQueue, offset);
    }