You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
808 B
808 B
ruoyi-test-mq
模块说明
- rabbitmq: 普通消息、延迟队列
- rocketmq：普通消息、事务消息、延迟消息
- kafka：普通消息
使用方式
rocketmq：
注意：由于rocketmq并没有自动创建topic的功能, 所以需要进入到rockerMQ文件路径中执行
创建普通消息的topic
sh mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c <cluster_name> -a +message.type=NORMAL
bin/mqadmin updatetopic -n localhost:9876 -t test-topic -c DefaultCluster
创建事务消息的topic
sh mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c <cluster_name> -a +message.type=TRANSACTION
bin/mqadmin updatetopic -n localhost:9876 -t transaction-topic -c DefaultCluster -a +message.type=TRANSACTION