支持amqp(RabbitMQ)

[qiqizjl]

对rabbitmq的支持

topic设置规则等同于rocketMQ和kafka
server端 topic=routekey
adapter端 topic=queue
目前exchnage/routekey/topic的绑定关系需要自行在rabbitmq manager中完成

若填写阿里uid且填写了阿里的ak和sk。则默认为阿里云MQ模式。若不需要则需要留空哦

# Vhost
canal.mq.vhost=
# 交换机
canal.mq.exchange=
# 用户名
canal.mq.username=
# 密码
canal.mq.password=
# 阿里UID
canal.mq.aliyunuid=

[CLAassistant]

All committers have signed the CLA.

[CLAassistant]

Thank you for your submission, we really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
_{You have signed the CLA already but the status is still pending? Let us recheck it.}

[codecov-io]

Codecov Report

Merging #2156 into master will decrease coverage by 0.05%.
The diff coverage is 0%.

@@             Coverage Diff             @@
##             master   #2156      +/-   ##
===========================================
- Coverage      6.15%    6.1%   -0.06%     
  Complexity      197     197              
===========================================
  Files           277     281       +4     
  Lines         26988   27214     +226     
  Branches       3995    4013      +18     
===========================================
  Hits           1661    1661              
- Misses        25063   25289     +226     
  Partials        264     264

Impacted Files	Coverage Δ	Complexity Δ
...ibaba/otter/canal/client/ConsumerBatchMessage.java	0% <ø> (ø)	0 <0> (?)
.../canal/client/rocketmq/RocketMQCanalConnector.java	0% <ø> (ø)	0 <0> (ø)	⬇️
...nal/client/rabbitmq/AliyunCredentialsProvider.java	0% <0%> (ø)	0 <0> (?)
...a/com/alibaba/otter/canal/common/MQProperties.java	0% <0%> (ø)	0 <0> (ø)	⬇️
...ba/otter/canal/rabbitmq/CanalRabbitMQProducer.java	0% <0%> (ø)	0 <0> (?)
...tter/canal/rabbitmq/AliyunCredentialsProvider.java	0% <0%> (ø)	0 <0> (?)
.../canal/client/rabbitmq/RabbitMQCanalConnector.java	0% <0%> (ø)	0 <0> (?)
... and 1 more

---

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 60e26d1...43abd9a. Read the comment docs.

[agapple]

tks

[JiaRG]

ConnectionFactory的host和port属性是分开设置的，这种构造方式存在问题

[JiaRG]

connect = factory.newConnection(com.rabbitmq.client.Address.parseAddresses(mqProperties.getServers()));

[yatang]

tks

[linghengqian]

It does not seem possible to modify the wiki through PR. The absence of documentation can be confusing to users.