泊闻
f5f4101abf
Change default group constant to "annoymous"
2 years ago
Bowen Li
5e80d7c2c4
refactor RocketMQProduceFactory: reuse producer ( #2699 )
...
* refactor RocketMQProduceFactory: Reuse producer
* 1. Change HashMap to ConcurrentHashMap
2. Don't reuse TransactionMQProducer
3. Add `sendCallBack` to key
* add some comments
* fix checkstyle
* add final to PRODUCER_REUSABLE_MAP
* add default group name for producer
2 years ago
Wu Daifu
cda0917a02
remove the redundant log(Fixes gh-2503) ( #2790 )
2 years ago
Wu Daifu
9cd3777b01
change logger from parent class to log in current class(Fixes gh-2366) ( #2788 )
2 years ago
Ceven Cheng
fcf8cd48ad
Fix MavenReportException problem ( #2776 )
...
* docs:polished the readme docs
perfect the sample documentation for Spring Cloud Alibaba Sidecar
* docs:polished the readme docs
Fix `nacos` password spelling error
* fix: Fix MavenReportException problem
2 years ago
sorie
5640ed971a
fix rocketmq check style
2 years ago
sorie
dfefc030c6
RocketMQ pollable support anonymous group.
2 years ago
sorie
a2a006b53b
RocketMQ 支持PollMessageSource
2 years ago
sorie
b8bcca486f
RocketMQ 支持PollMessageSource
2 years ago
sorie
35d5fa6e9a
RocketMQ 支持PollMessageSource
2 years ago
misselvexu
cfbf11fd8b
Add maxReconsumeTimes support .
3 years ago
chengpu.rzh
290dfa7211
Reformat the codes
3 years ago
sorie
28919b7bba
Fix rocketmq example and style
3 years ago
sorie
d4efc222da
rocketmq anonymous group test: use AssertJ instead of Junit5
...
(cherry picked from commit 38b963ede0
)
3 years ago
sorie
e0b22c68d1
rocketmq anonymous group test: use AssertJ instead of Junit5
...
(cherry picked from commit 63ade07329
)
3 years ago
sorie
be11c5054c
rocketmq anonymous group supports.
3 years ago
sorie
89a7287b38
rocketmq multi-broker offset error and blank header support
3 years ago
mcy
1390640692
Update RocketMQProducerMessageHandler.java
3 years ago
jinghao
d66fb6b89c
Modified the log level of RocketMQProducerMessageHandler.
3 years ago
misselvexu
84a43fe195
Rename HealthIndicatorConfiguration .
3 years ago
misselvexu
6d9fe2d5cb
Upgrade rocketmq 4.9.3 .
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
4 years ago
zkzlx
745d173898
message converter
4 years ago
zkzlx
b35e7d7877
fixed Instrumentation
4 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
Spike
10e9a99d08
issue#2040
...
转移RocketMQConfigBeanPostProcessor和CompositeMessageConverter从RocketMQBinderAutoConfiguration至ExtendedBindingHandlerMappingsProviderConfiguration
从RocketMQBinderAutoConfiguration中注入会被stream代理生成一个新的上下文层,上层使用者和它会被隔离导致无法使用
原来是通过spirng.binders经过spring-cloud-stream代理
4 years ago
Spike
ba80fcac2f
#checkstyle removed unused import
4 years ago
Spike
1f9f10ce90
issue#2040
...
移除RocketMQConfigBeanPostProcessor在RocketMQBinderAutoConfiguration类中的注入,改为通过spirng.factories注入,原来是通过spirng.binders经过spring-cloud-stream代理
4 years ago
zkzlx
9379d18ace
Code style
4 years ago
zkzlx
6d7c47a366
Code refactoring and some new feature support - delete some invalid files.
4 years ago
zkzlx
c1c5597171
Code refactoring and some new feature support - delete some invalid files.
4 years ago
zkzlx
5a763e0ec9
Code refactoring and some new feature support - delete some invalid files.
4 years ago
zkzlx
a6e01c9984
Code refactoring and some new feature support
4 years ago
zkzlx
cbd64061ce
Code refactoring and some new feature support
4 years ago
mercyblitz
5cd6c0f1e7
Fix the code style issues
5 years ago
delicious
ec06f97aa0
Update RocketMQMessageChannelBinder.java
...
use AbstractMessageChannel.getInterceptors() to replace ChannelInterceptorAware.getChannelInterceptors()
5 years ago
mercyblitz
a198133852
Update pom.xml
5 years ago
fudali113
a218e6f5ce
feat: use ConditionalOnEnabledHealthIndicator condition with NacosConfigHealthIndicator & AcmHealthIndicator & RocketMQBinderHealthIndicator & SidecarHealthIndicator
...
[fix #1276 ] https://github.com/alibaba/spring-cloud-alibaba/issues/1276
5 years ago
mercyblitz
d57cbc2e4d
Polish alibaba/spring-cloud-alibaba/#1283 : Renaming spring-cloud-starter-alibaba to be spring-cloud-alibaba-starters
5 years ago