615d4911bf
rocketmq consumer support some config item ( #2811 )
...
Signed-off-by: Naah <nayan3480232@163.com>
Signed-off-by: Bernd Verst <github@bernd.dev>
Co-authored-by: Deepanshu Agarwal <deepanshu.agarwal1984@gmail.com>
Co-authored-by: Bernd Verst <github@bernd.dev>
2023-05-04 10:57:03 -07:00
875abcda56
Add rocketmq configuration items. Add orderly message. ( #2198 )
...
* Add rocketmq configuration items. Add orderly message. Change the version of rocketmq-client-go to v2.1.0.
Signed-off-by: jinjianfeng-chn <feng081212@163.com>
* modtidy
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: jinjianfeng-chn <feng081212@163.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
2022-11-10 11:54:40 -08:00
a6ad8cb4bf
RocketMQ fix metadata properties ( #1817 )
...
* Removes the useless metadata attributes, AccessProto and ConsumerBatchSize, rename GroupName to ProducerGroup
Signed-off-by: helbing <helbingxxx@gmail.com>
* RocketMQ SendTimeout unit is seconds
Signed-off-by: helbing <helbingxxx@gmail.com>
* avoid breaking change
Signed-off-by: helbing <helbingxxx@gmail.com>
* implement ConsumerBatchSize option
Signed-off-by: helbing <helbingxxx@gmail.com>
* avoid breaking change
Signed-off-by: helbing <helbingxxx@gmail.com>
* add deprecated log
Signed-off-by: helbing <helbingxxx@gmail.com>
* backwards-compatibility sendTimeOut
Signed-off-by: helbing <helbingxxx@gmail.com>
* fix lint
Signed-off-by: helbing <helbingxxx@gmail.com>
* add logger import
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Signed-off-by: helbing <helbingxxx@gmail.com>
Signed-off-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
Co-authored-by: addjuarez <addiajuarez@gmail.com>
Co-authored-by: Dapr Bot <56698301+dapr-bot@users.noreply.github.com>
Co-authored-by: Bernd Verst <4535280+berndverst@users.noreply.github.com>
2022-09-14 14:45:47 -07:00
8964d8bf41
Define common metadata across components ( #1994 )
...
* Add base metadata for all components
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
* Fix lint issues on consul and mysql tests
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
* Pin candeia/dapr runtime version
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
* Add replace directive to use mcandeia/dapr on all go submodules
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
* Fixed runtime config instantiation
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
Signed-off-by: Marcos Candeia <marrcooos@gmail.com>
2022-08-25 10:10:53 -07:00
c7adb917f3
update license to Apache v2.0 ( #1406 )
2022-01-04 19:53:31 -08:00
5c9365b314
pub/sub rocketmq:upgrade with v2 ( #1383 )
...
* pub/sub rocketmq:upgrade with client v2
Signed-off-by: zach <zachchou016@gmail.com>
* pubsub/rocketmq:remove cache and add start with setup
Signed-off-by: zach <zachchou016@gmail.com>
* pubsub/rocketmq:fix variable golint
Signed-off-by: zach <zachchou016@gmail.com>
* pubsub/rocketmq:change license and fix goimports
Signed-off-by: zach <zachchou016@gmail.com>
Co-authored-by: Looong Dai <long.dai@intel.com>
2021-12-31 12:18:27 -08:00
Naah
jinjianfeng-chn
Bruce Huang
Marcos Candeia
Dmitry Shmulevich
Zach