Skip to content

Commit

Permalink
release 0.0.5
Browse files Browse the repository at this point in the history
  • Loading branch information
pufang committed Nov 9, 2017
1 parent 8993ed7 commit 3568124
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
<dependency>
<groupId>com.maihaoche</groupId>
<artifactId>spring-boot-starter-rocketmq</artifactId>
<version>0.0.4</version>
<version>0.0.5</version>
</dependency>
```

Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@

<groupId>com.maihaoche</groupId>
<artifactId>spring-boot-starter-rocketmq</artifactId>
<version>0.0.5-SNAPSHOT</version>
<version>0.0.5</version>

<scm>
<url>https://github.com/maihaoche/rocketmq-spring-boot-starter</url>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,14 +16,18 @@
public @interface MQConsumer {
String consumerGroup();
String topic();

/**
* 广播模式消费: BROADCASTING
* 集群模式消费: CLUSTERING
* @return 消息模式
*/
String messageMode() default MessageExtConst.MESSAGE_MODE_CLUSTERING;

/**
* 使用线程池并发消费: CONCURRENTLY("CONCURRENTLY"),
* 单线程消费: ORDERLY("ORDERLY");
* @return 消费模式
*/
String consumeMode() default MessageExtConst.CONSUME_MODE_CONCURRENTLY;
String[] tag() default {"*"};
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,13 +12,9 @@
import org.springframework.util.Assert;

/**
* Comments:RocketMQ消费抽象基类
* Author:Jay Chang
* Create Date:2017/9/14
* Description:RocketMQ消费抽象基类
* Created by Jay Chang on 2017/9/14
* Modified By:
* Modified Date:
* Why & What is modified:
* Version:v1.0
*/
@Slf4j
public abstract class AbstractMQConsumer<T> {
Expand Down

0 comments on commit 3568124

Please sign in to comment.