package cn.axzo.workflow.starter.mq.broadcast.filter;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * 过滤 MQ 消息, 不再对其进行消费
 *
 * @author wangli
 * @since 2024/6/4 17:12
 */
public interface InnerMessageQueueHandleBeforeFilter {

    /**
     * 传入 RocketMQ 底层的消息对象,对消费过程中的消息过滤
     *
     * @param message
     * @return 为 true 时,代表需要被过滤
     */
    boolean doFilter(MessageExt message);

}
