Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

能不能给注解 MqConsumer 增加开关,并且支持spring 的变量 实现? #29

Open
zkname opened this issue Feb 7, 2025 · 0 comments

Comments

@zkname
Copy link

zkname commented Feb 7, 2025

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
public @interface MqConsumer {

    public static final String DEFAULT_GROUP = "DEFAULT";   // default group
    public static final String EMPTY_GROUP = "";            // empty group means consume broadcase message, will replace by uuid

    public static final String OPEN = "OPEN";
    public static final String CLOSE = "CLOSE";

    /**
     * @return
     */
    String group() default DEFAULT_GROUP;

    /**
     * @return
     */
    String topic();

    /**
     * @return
     */
    boolean transaction() default true;

    /**
     * 消费开关
     * @return
     */
    String open() default OPEN;

}

类似于
@MqConsumer(topic = "test_${xxl.mq.env}", open = "${xxl.mq.open}")

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant