stream/AbstractRedisStreamMessageListener.java

Abstract listener for Redis Stream messages with interceptor support, enabling cluster consumption and message acknowledgment.

// Source: https://github.com/YunaiV/ruoyi-vue-pro | License: MIT | Copyright 2021 ruoyi-vue-pro
// Provided via justclaw.it.com; keep this notice with the code.
package cn.iocoder.yudao.framework.mq.redis.core.stream;

import cn.hutool.core.util.TypeUtil;
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
import cn.iocoder.yudao.framework.mq.redis.core.RedisMQTemplate;
import cn.iocoder.yudao.framework.mq.redis.core.interceptor.RedisMessageInterceptor;
import cn.iocoder.yudao.framework.mq.redis.core.message.AbstractRedisMessage;
import lombok.Getter;
import lombok.Setter;
import lombok.SneakyThrows;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.connection.stream.ObjectRecord;
import org.springframework.data.redis.stream.StreamL

... (truncated -- full source via MCP)