Skip to content

Commit 68388af

Browse files
committed
feat: rocketmq 使用示例
1 parent 2c306d1 commit 68388af

36 files changed

+861
-440
lines changed

codes/javatech/javatech-mq/javatech-rocketmq/pom.xml

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,12 @@
2727
<dependency>
2828
<groupId>org.apache.rocketmq</groupId>
2929
<artifactId>rocketmq-client</artifactId>
30-
<version>4.2.0</version>
30+
<version>4.9.4</version>
31+
</dependency>
32+
<dependency>
33+
<groupId>org.apache.rocketmq</groupId>
34+
<artifactId>rocketmq-logging</artifactId>
35+
<version>4.9.4</version>
3136
</dependency>
3237
<dependency>
3338
<groupId>ch.qos.logback</groupId>

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/AsyncProducer.java

Lines changed: 0 additions & 45 deletions
This file was deleted.

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/BatchProducer.java

Lines changed: 0 additions & 94 deletions
This file was deleted.

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/BroadcastConsumer.java

Lines changed: 0 additions & 44 deletions
This file was deleted.

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/BroadcastProducer.java

Lines changed: 0 additions & 29 deletions
This file was deleted.

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/OnewayProducer.java

Lines changed: 0 additions & 32 deletions
This file was deleted.

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/OrderedConsumer.java

Lines changed: 0 additions & 56 deletions
This file was deleted.

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/RocketConfig.java

Lines changed: 0 additions & 10 deletions
This file was deleted.
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
package io.github.dunwu.javatech.rocketmq;
2+
3+
/**
4+
* @author Zhang Peng
5+
*/
6+
public class RocketConstant {
7+
8+
public static final String HOST = "localhost:9876";
9+
10+
}

codes/javatech/javatech-mq/javatech-rocketmq/src/main/java/io/github/dunwu/javatech/rocketmq/ScheduledMessageConsumer.java

Lines changed: 0 additions & 40 deletions
This file was deleted.

0 commit comments

Comments
 (0)