summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #1831 from rabbitmq/make-mandatory-based-on-routing-onlyMichael Klishin2019-01-163-54/+18
|\ | | | | Make mandatory based on route data only
| * Merge branch 'master' into make-mandatory-based-on-routing-onlyMichael Klishin2019-01-161-9/+7
| |\
| * | Make mandatory based on route data onlykjnilsson2019-01-153-54/+18
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Instead of waiting for a mandatory_received message from the queue the mandatory result is calculated in the channel based on the routing result only. This may seem like a weakening of the mandatory semantics but considering that the mandatory_received message is returned _before_ the message is enqueued and/or persisted in the queue it doesn't actually open up any further failure scenarios. [#163222515]
* | | Merge pull request #1823 from rabbitmq/delete_quorum_queue_fixesMichael Klishin2019-01-163-21/+57
|\ \ \ | |_|/ |/| | Improve quorum queue deletion
| * | Change quorum queue delete timeoutkjnilsson2019-01-151-12/+20
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The default timeout of net_ticktime + 5000 ms was much too long and made the delete operation in the management UI timeout and not complete properly. A simple 5000ms works better and this commit also handles the case where the delete command was committed but the leader never shut down due to a server being unavailable. This also falls back to forced deletion. [#163062078]
| * | Log this as a warningMichael Klishin2019-01-151-1/+1
| | |
| * | Improve quorum queue deletionkjnilsson2019-01-153-20/+48
| |/ | | | | | | | | | | Only delete the amqqueue record after successful Ra cluster deletion. Force delete Ra servers when not able to achieve consensus.
* | Merge pull request #1836 from rabbitmq/rabbitmq-server-1835Michael Klishin2019-01-161-9/+7
|\ \ | |/ |/| Remove use of accept_ack
| * Remove use of accept_ackLuke Bakken2019-01-151-9/+7
|/ | | | | | Ranch no longer calls accept_ack for a transport, which means a couple important operations are missed for new sockets. Fixes #1835
* Merge pull request #1819 from rabbitmq/qq-testingMichael Klishin2019-01-158-57/+344
|\ | | | | Testing of quorum queues
| * Merge branch 'master' into qq-testingMichael Klishin2019-01-151-29/+212
| |\ | |/ |/| | | | | Conflicts: src/rabbit_fifo.erl
* | Merge pull request #1827 from ↵Michael Klishin2019-01-141-27/+212
|\ \ | | | | | | | | | | | | rabbitmq/rabbitmq-server-1825-single-active-consumer-in-qq-leaks-consumers Clean consumers properly in QQ when single active consumer is on
| * | Add waiting consumers when listing consumers in QQArnaud Cogoluègnes2019-01-141-11/+47
| | | | | | | | | | | | | | | Necessary when single active consumer is on, otherwise only the single active consumer shows up in the command line.
| * | (Un)suspect waiting consumers when node goes down or upArnaud Cogoluègnes2019-01-141-7/+76
| | | | | | | | | | | | For single active consumer.
| * | Unregister waiting consumers in QQ when channel goes downArnaud Cogoluègnes2019-01-111-9/+89
| | | | | | | | | | | | | | | | | | | | | | | | For single active consumer. Otherwise they still show up in the management plugin. Worse, a consumer from a dead channel can end up being the single active consumer, which stops deliveries. References #1825
| | * Remove an unused recordMichael Klishin2019-01-141-1/+0
| | |
| | * Merge branch 'master' into qq-testingMichael Klishin2019-01-14218-1031/+446
| | |\ | |_|/ |/| |
* | | Merge pull request #1830 from samnela/fix/copyright-yearMichael Klishin2019-01-14215-246/+238
|\ \ \ | |/ / |/| | Fixed years in copyright
| * | Fixed years in copyrightSamuel NELA2019-01-13215-246/+238
|/ /
* | Merge pull request #1821 from rabbitmq/lrb-update-sysmon_handlerLuke Bakken2019-01-094-794/+203
|\ \ | | | | | | Update to sysmon_handler 1.1.0
| * | Debug log messageMichael Klishin2019-01-101-1/+1
| | |
| * | Update to sysmon_handler 1.1.0Luke Bakken2019-01-095-795/+204
| | | | | | | | | | | | Also ensure that sane defaults are used for sysmon_handler if not set by the user
* | | Update rabbitmq-components.mkLuke Bakken2019-01-091-1/+1
|/ /
* | Correct a max message size config setting typoMichael Klishin2019-01-092-1/+15
| | | | | | | | Discovered while doing acceptance. References #1812.
| * Merge remote-tracking branch 'origin/master' into qq-testingDiana Corbacho2019-01-1025-394/+2427
| |\ | |/ |/|
* | Update ct-config_schema expectations to include sysmon_handler defaultsMichael Klishin2019-01-091-83/+750
| | | | | | | | | | This is a short term solution, the generated config helpers/framework is due for revisiting.
* | Squash a couple of warningsMichael Klishin2019-01-091-2/+2
| |
* | Merge pull request #1816 from rabbitmq/rabbitmq-server-952Michael Klishin2019-01-096-2/+493
|\ \ | | | | | | Add sysmon-handler to RabbitMQ
| * | Add rabbitmq-sysmon to RabbitMQLuke Bakken2019-01-076-2/+493
| | | | | | | | | | | | | | | | | | | | | | | | Fixes #952 Update for rabbitmq-sysmon -> sysmon-handler rename Use hex.pm package for sysmon_handler, copy schema into rabbit.schema
* | | Merge pull request #1802 from ↵Michael Klishin2019-01-097-99/+762
|\ \ \ | | | | | | | | | | | | | | | | rabbitmq/rabbitmq-server-1799-single-active-consumer-in-qq Single active consumer
| * \ \ Merge branch 'master' into rabbitmq-server-1799-single-active-consumer-in-qqMichael Klishin2019-01-0815-195/+402
| |\ \ \
| * | | | NbMessages => MessageCountMichael Klishin2019-01-081-24/+24
| | | | |
| * | | | Simplify consumer cancellation in QQ for single active consumerArnaud Cogoluègnes2019-01-081-16/+8
| | | | | | | | | | | | | | | | | | | | References #1799
| * | | | Clarify commentsMichael Klishin2019-01-081-2/+2
| | | | | | | | | | | | | | | | | | | | (cherry picked from commit 14e232f2afbd4dd212f0eae1c4efcde3d250b11e)
| * | | | FormattingMichael Klishin2019-01-082-2/+2
| | | | | | | | | | | | | | | | | | | | (cherry picked from commit 7c2815912966e3683d8cc2155dfd321aa56df6cd)
| * | | | FormattingMichael Klishin2019-01-081-12/+13
| | | | | | | | | | | | | | | | | | | | (cherry picked from commit 28bef208e44a11af12e4b2d000c9ff52a60f54a1)
| * | | | Add unit test for single active consumer in quorum queuesArnaud Cogoluègnes2019-01-081-8/+67
| | | | | | | | | | | | | | | | | | | | References #1799
| * | | | Address comments after single active consumer reviewArnaud Cogoluègnes2019-01-081-35/+39
| | | | | | | | | | | | | | | | | | | | References #1799
| * | | | Merge branch 'master' into rabbitmq-server-1799-single-active-consumer-in-qqArnaud Cogoluègnes2018-12-219-272/+362
| |\ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: src/rabbit_quorum_queue.erl
| * \ \ \ \ Merge branch 'master' into rabbitmq-server-1799-single-active-consumer-in-qqArnaud Cogoluègnes2018-12-143-28/+163
| |\ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: src/rabbit_fifo.erl src/rabbit_quorum_queue.erl
| * | | | | | Support single active consumer in quorum queueArnaud Cogoluègnes2018-12-143-42/+188
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Uses a buffer list for non-active consumers. The active consumer is stored in the usual consumers structure, so the logic around servicing consumers is kept the same. [#162582065] Fixes #1799
| * | | | | | Merge branch 'master' into rabbitmq-server-1799-single-active-consumer-in-qqArnaud Cogoluègnes2018-12-1410-542/+509
| |\ \ \ \ \ \
| * \ \ \ \ \ \ Merge branch 'master' into rabbitmq-server-1743-exclusive-consumerArnaud Cogoluègnes2018-12-1131-339/+1668
| |\ \ \ \ \ \ \
| * | | | | | | | Don't use exclusive consumer info item for single active consumerArnaud Cogoluègnes2018-11-301-7/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Single active consumer will have its own info item. [#161090309] References #1743
| * | | | | | | | Use single active consumer term when appropriateArnaud Cogoluègnes2018-11-223-63/+63
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | References #1743
| * | | | | | | | Merge branch 'master' into rabbitmq-server-1743-exclusive-consumerArnaud Cogoluègnes2018-11-2247-437/+6700
| |\ \ \ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: src/rabbit_amqqueue.erl src/rabbit_amqqueue_process.erl
| * | | | | | | | | Use x-single-active-consumer queue argumentArnaud Cogoluègnes2018-10-253-5/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Instead of x-exclusive-consumer. [#161090309] References #1743
| * | | | | | | | | Check exclusive consumer isn't blocked before deliveryArnaud Cogoluègnes2018-10-242-10/+24
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | References #1743
| * | | | | | | | | Forbid AMQP exclusive consume in exclusive consumer queueArnaud Cogoluègnes2018-10-242-31/+47
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | [#161090309] References #1743
| * | | | | | | | | Pick new exclusive consumer after channel goes downArnaud Cogoluègnes2018-10-233-71/+178
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | [#161090309] References #1743
View Lorry Controller Status