RocketMQ EventBridge 如何扩展参数验证
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-eventbridge-infrastructure</artifactId> <version>1.0.0</version> </dependency>
public class XXXXAuthValidation implements AuthValidation { @Override public Context validate(ServerHttpRequest request, Context ctx) { ... return ctx.put(keyxxx, valxxxx); } @Override public String getType() { return "验证器名称"; } }
/resources/ |——META-INF | |——services | |——org.apache.rocketmq.eventbridge.infrastructure.validate.AuthValidation | org.apache.rocketmq.eventbridge.infrastructure.validate.XXXXAuthValidation
auth.validation=验证器名称(如有多个以逗号分割)