| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.rocketmq.spring.annotation; |
| |
| import org.springframework.stereotype.Component; |
| |
| import java.lang.annotation.Documented; |
| import java.lang.annotation.ElementType; |
| import java.lang.annotation.Retention; |
| import java.lang.annotation.RetentionPolicy; |
| import java.lang.annotation.Target; |
| |
| @Target(ElementType.TYPE) |
| @Retention(RetentionPolicy.RUNTIME) |
| @Documented |
| @Component |
| public @interface ExtRocketMQConsumerConfiguration { |
| |
| String NAME_SERVER_PLACEHOLDER = "${rocketmq.name-server:}"; |
| String GROUP_PLACEHOLDER = "${rocketmq.consumer.group:}"; |
| String TOPIC_PLACEHOLDER = "${rocketmq.consumer.topic:}"; |
| String ACCESS_CHANNEL_PLACEHOLDER = "${rocketmq.access-channel:}"; |
| String ACCESS_KEY_PLACEHOLDER = "${rocketmq.consumer.access-key:}"; |
| String SECRET_KEY_PLACEHOLDER = "${rocketmq.consumer.secret-key:}"; |
| String TRACE_TOPIC_PLACEHOLDER = "${rocketmq.consumer.customized-trace-topic:}"; |
| |
| /** |
| * The component name of the Producer configuration. |
| */ |
| String value() default ""; |
| |
| /** |
| * The property of "name-server". |
| */ |
| String nameServer() default NAME_SERVER_PLACEHOLDER; |
| |
| /** |
| * The property of "access-channel". |
| */ |
| String accessChannel() default ACCESS_CHANNEL_PLACEHOLDER; |
| |
| /** |
| * Group name of consumer. |
| */ |
| String group() default GROUP_PLACEHOLDER; |
| |
| /** |
| * Topic name of consumer. |
| */ |
| String topic() default TOPIC_PLACEHOLDER; |
| |
| /** |
| * Control message mode, if you want all subscribers receive message all message, broadcasting is a good choice. |
| */ |
| MessageModel messageModel() default MessageModel.CLUSTERING; |
| |
| /** |
| * Control how to selector message. |
| * |
| * @see SelectorType |
| */ |
| SelectorType selectorType() default SelectorType.TAG; |
| |
| /** |
| * Control which message can be select. Grammar please see {@link SelectorType#TAG} and {@link SelectorType#SQL92} |
| */ |
| String selectorExpression() default "*"; |
| |
| /** |
| * The property of "access-key". |
| */ |
| String accessKey() default ACCESS_KEY_PLACEHOLDER; |
| |
| /** |
| * The property of "secret-key". |
| */ |
| String secretKey() default SECRET_KEY_PLACEHOLDER; |
| |
| /** |
| * Maximum number of messages pulled each time. |
| */ |
| int pullBatchSize() default 10; |
| |
| /** |
| * The property of "tlsEnable" default false. |
| */ |
| String tlsEnable() default "false"; |
| |
| /** |
| * Switch flag instance for message trace. |
| */ |
| boolean enableMsgTrace() default false; |
| |
| /** |
| * The name value of message trace topic.If you don't config,you can use the default trace topic name. |
| */ |
| String customizedTraceTopic() default TRACE_TOPIC_PLACEHOLDER; |
| } |