| commit | 895e6f2c2a9c69652dde0fcef74e8aa4c510420f | [log] [tgz] |
|---|---|---|
| author | Fangbin Sun <sunfangbin@gmail.com> | Tue Apr 02 00:35:34 2019 +0800 |
| committer | Sijie Guo <guosijie@gmail.com> | Mon Apr 01 09:35:34 2019 -0700 |
| tree | 8330da5f31c7068d6cec222b1487ae7a3c7d0c3e | |
| parent | 6508e5e7ad2e573449c11b3097800b1e42203984 [diff] |
Some minor improvement of RabbitMQ IO Source. (#3937) ### Motivation This PR try to add some specific config for RabbitMQ IO Source to support setting `basicQos` and `ack`. ### Modifications * Add an abstract `RabbitMQAbstractConfig` and `RabbitMQSourceConfig` inherits from it. * Add some unit tests.