private static int putIfPresent()

in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java [93:112]

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

    private static int putIfPresent(String key, Object value, Message rocketMQMsg) {
        int len = 0;
        if (value instanceof String && StringUtils.isNotEmpty((String) value)) {
            rocketMQMsg.putUserProperty(key, (String) value);
            len = key.length() + ((String) value).length() + 2;
        } else if (value instanceof Number) {
            String str = String.valueOf(value);
            rocketMQMsg.putUserProperty(key, str);
            len = key.length() + str.length() + 2;
        } else if (value instanceof URI) {
            String str = value.toString();
            rocketMQMsg.putUserProperty(key, str);
            len = key.length() + str.length() + 2;
        } else if (value instanceof ZonedDateTime) {
            String str = ((ZonedDateTime) value).format(DateTimeFormatter.ISO_OFFSET_DATE_TIME);
            rocketMQMsg.putUserProperty(key, str);
            len = key.length() + str.length() + 2;
        }
        return len;
    }