Bowen Li
|
74ee0a65ae
|
Fix: pollable consumer doesn't ack the message correctly (#3248)
|
2 years ago |
YuLuo
|
1eacea72d0
|
update copyright in 2022.x (#3125)
|
2 years ago |
panzhi
|
c01748316d
|
fix RocketMQ SecretKey leakage risk (#3091)
fix RocketMQ SecretKey leakage risk
|
2 years ago |
ruansheng
|
42e6fa4cd9
|
Fix rocketMQ test case
|
2 years ago |
MieAh
|
2815b745ac
|
Optimized with jdk new features (#2972)
* Optimize switch expressions.
* Optimize instanceOf to determine pattern matching
* Optimize switch expressions.
* Optimize instanceOf to determine pattern matching
|
2 years ago |
|
ruansheng
|
2210917cd1
|
Fix #2963 RocketMQ binder test NPE
|
2 years ago |
|
ruansheng
|
36a428c4a4
|
Update todo info
|
2 years ago |
|
ruansheng
|
800c89bfec
|
ignore rocketmq stream binder test
|
2 years ago |
|
ruansheng
|
d53ac12bec
|
update spring.factories to auto-configuration
|
2 years ago |
Sorie
|
8c0f1a26fb
|
Fix rocketmq bus. (#2794)
* Fix rocketmq bus.
* Fix nacos test and add boostrap dependency in spring-cloud-bus-rocketmq-example
|
2 years ago |
Wu Daifu
|
4266809b63
|
change logger from parent class to log in current class(Fixes gh-2366) (#2791)
|
2 years ago |
|
Wu Daifu
|
ed26351e93
|
Fix issue 2698: resolve errors in generating javadocs by mvn install (#2781)
|
2 years ago |
windwheel
|
b53de81b7a
|
remove code
|
2 years ago |
|
sorie
|
6d21378420
|
Fix rocketmq test
|
2 years ago |
|
windwheel
|
851cd68984
|
fix message channel transfer
|
2 years ago |
|
windwheel
|
10deb9cbcd
|
add register channel
|
2 years ago |
|
windwheel
|
68bb568ee4
|
add channel outout collector
|
2 years ago |
|
sorie
|
ec09b74c85
|
Fix rocketmq code style
|
3 years ago |
|
sorie
|
89fcf32f2e
|
RocketMQ pollable support anonymous group.
|
3 years ago |
|
sorie
|
45b30da838
|
RocketMQ code style
|
3 years ago |
|
sorie
|
cc7a169025
|
RocketMQ 支持PollMessageSource
|
3 years ago |
|
sorie
|
accc42c399
|
rocketmq multi-broker offset error code style
|
3 years ago |
|
sorie
|
686fb65aa0
|
rocketmq blank header support test
|
3 years ago |
sorie
|
7a4a962735
|
rocketmq multi-broker offset error
|
3 years ago |
|
sorie
|
62ff55cd16
|
rocketmq multi-broker offset error
|
3 years ago |
Freeman Lau
|
5fd76cde30
|
Fix wrong class name
|
3 years ago |
mcy
|
c4d81e9641
|
Update RocketMQProducerMessageHandler.java
Add whitespace after 'if'.
|
3 years ago |
jinghao
|
8715987fbf
|
Modified the log level of RocketMQProducerMessageHandler.
|
3 years ago |
|
sorie
|
38b963ede0
|
rocketmq anonymous group test: use AssertJ instead of Junit5
|
3 years ago |
|
sorie
|
63ade07329
|
rocketmq anonymous group test: use AssertJ instead of Junit5
|
3 years ago |
|
sorie
|
ead86ec2db
|
rocketmq anonymous group supports.
|
3 years ago |
|
sorie
|
ac80858241
|
rollback null group support, it makes some mistakes.
|
3 years ago |
|
sorie
|
0cd03778fa
|
Write some tests for #2391
|
3 years ago |
|
sorie
|
bd800de133
|
Fixs group must be configured for channel #2391
And delete rocketmq-comprehensive-example's consumer group configurations.
|
3 years ago |
|
Freeman Lau
|
842ea176c0
|
Upgrade RocketMQ to 4.9.2.
fix when 'spring-boot-starter-actuator' doesn't exist, throw ClassNotFount.
add example.
optimize pom.
|
3 years ago |
|
Freeman Lau
|
1a7f900a9c
|
Merge 2.2.x to 2022.
fix conflict and checkstyle
|
3 years ago |
|
Freeman Lau
|
22008adf25
|
Merge remote-tracking branch 'upstream/2022.x' into merge_2.2.x_2022
# Conflicts:
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQBinderUtils.java
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/config/RocketMQComponent4BinderAutoConfiguration.java
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/consuming/RocketMQListenerBindingContainer.java
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageSource.java
|
3 years ago |
|
Freeman Lau
|
3451906c2b
|
Merge 2.2.x to 2022.
|
3 years ago |
|
Freeman Lau
|
42f03eb1c8
|
Merge remote-tracking branch 'upstream/2.2.x' into merge_2.2.x_2022
# Conflicts:
# README-zh.md
# pom.xml
# spring-cloud-alibaba-dependencies/pom.xml
# spring-cloud-alibaba-docs/src/main/asciidoc-zh/nacos-discovery.adoc
# spring-cloud-alibaba-docs/src/main/asciidoc/nacos-discovery.adoc
# spring-cloud-alibaba-examples/nacos-example/nacos-discovery-example/nacos-discovery-provider-example/src/main/java/com/alibaba/cloud/examples/ProviderApplication.java
# spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-config/src/main/java/com/alibaba/cloud/nacos/client/NacosPropertySource.java
# spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-config/src/main/resources/META-INF/spring.factories
# spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-discovery/src/main/java/com/alibaba/cloud/nacos/NacosDiscoveryProperties.java
# spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-nacos-discovery/src/test/java/com/alibaba/cloud/nacos/ribbon/NacosRibbonClientPropertyOverrideTests.java
# spring-cloud-alibaba-starters/spring-cloud-starter-alibaba-sentinel/src/main/java/com/alibaba/cloud/sentinel/feign/SentinelFeign.java
# spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/RocketMQMessageHandler.java
|
3 years ago |
|
Freeman Lau
|
3c67351907
|
Refactor deprecated code.
1. Spring 的 StringUtils#isEmpty 已经过时, 使用 spring-cloud-alibaba-commons 下的 StringUtils 替换, 如果同时还使用了
Spring StringUtils 的其他方法, 那么将使用 StringUtils#hasLength 取反替换
2. 移除类 NacosRefreshProperties
3. 优化pom, 删除重复依赖
4. 尽可能地优化 deprecated class and method
优化过后将完全消除打包构建时黄色警告⚠️
|
3 years ago |
李志威
|
941bdad484
|
fix the checkstyle plugin error
```shell
[INFO] --- maven-checkstyle-plugin:3.0.0:check (checkstyle-validation) @ spring-cloud-starter-stream-rocketmq ---
[INFO] 开始检查……
[ERROR] /Users/lizhiwei/Git/github/spring-cloud-alibaba/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/autoconfigurate/ExtendedBindingHandlerMappingsProviderConfiguration.java:59: 需要一个 Javadoc注释 @return 。 [JavadocMethod]
检查完成。
[INFO] ------------------------------------------------------------------------
```
|
3 years ago |
zkzlx
|
3e8380740c
|
Optimize the code of producer
|
3 years ago |
|
zkzlx
|
9cba216bfa
|
Optimize the consumption of Pull
|
3 years ago |
|
zkzlx
|
bc6c89f1bc
|
Merge branch 'rocketmq' of github.com:alibaba/spring-cloud-alibaba into rocketmq
|
3 years ago |
|
zkzlx
|
745d173898
|
message converter
|
3 years ago |
|
zkzlx
|
b35e7d7877
|
fixed Instrumentation
|
3 years ago |
TheoneFx
|
72e8a3bb36
|
Merge pull request #2103 from joeqiaoyao/rocketmq
feat: 配置添加unitName，支持同一应用连接多个集群
|
4 years ago |
|
zkzlx
|
568c64b1cf
|
document
|
4 years ago |
joeqiaoyao
|
87d0939411
|
feat: 配置添加unitName，支持同一应用连接多个集群
|
4 years ago |
Spike
|
c138dd17ac
|
fix check style
|
4 years ago |