summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Make master locator min-masters count queues and not bindings.Daniil Fedotov2018-12-281-41/+29
| | | | | | | | | | | The min-masters locator was originally designed to count bindings, but this was confusing for people wanting to distribute queues rather than routes to queues. This was changed in 1d413eac80c2adb6844b82c8ce57e21a04a55b04 to count only queues which have at least one binding. But queues always have bindings (default) and hence it's equivalent to listing queues. Since default bindings are removed the location was broken. This commit changes the location to actually list queues rather than bindings.
* Do not create default bindings for queues.Daniil Fedotov2018-12-281-11/+1
| | | | | | | Routing from default exchange is performed without querying bindings and they cannot be unbound and only show in `rabbitmqctl list_bindings`. There is no point in keeping them and they are slowing down cleanup.
* Merge pull request #1809 from rabbitmq/qq-purge-bug-fixD Corbacho2018-12-243-28/+23
|\ | | | | Quorum queue: purge should not remove checkout out messages.
| * Quorum queue: purege should not remove checkout out messages.kjnilsson2018-12-213-28/+23
|/ | | | | | As these may be returned by a consumer after the purge. [#162811681]
* Merge pull request #1808 from rabbitmq/ra_machine_apply_3Michael Klishin2018-12-213-182/+203
|\ | | | | rabbit_fifo: apply/4 -> apply/3
| * rabbit_fifo: apply/4 -> apply/3kjnilsson2018-12-203-182/+203
|/ | | | Support the latest Ra api changes.
* Merge pull request #1807 from rabbitmq/redlivery-count-fixMichael Klishin2018-12-192-4/+5
|\ | | | | Do not include x-delivery-count header on first delivery.
| * Do not include x-delivery-count header on first delivery.kjnilsson2018-12-192-4/+5
|/ | | | [#162755631]
* Squash a warningMichael Klishin2018-12-191-2/+2
|
* Merge pull request #1806 from rabbitmq/report-message-bytesMichael Klishin2018-12-191-2/+9
|\ | | | | quorum queue: reset message bytes on purge
| * quorum queue: reset message bytes on purgekjnilsson2018-12-191-2/+9
|/ | | | [#161505138]
* Merge pull request #1803 from rabbitmq/vanlightly-bugsD Corbacho2018-12-195-83/+134
|\ | | | | Bugfixes
| * Quorum queue: fix crash bug after reconnectionkjnilsson2018-12-182-24/+36
| | | | | | | | | | | | | | | | | | | | | | When a consumer node is disconnected the quorum queue will return all outstanding messages for the consumer to the queue as it cannot know if the consumer will ever come back or not and cannot leave things checked out forever. If the consumer node then reconnectes and the consumer channel is still alive it may try to query for missing deliveries and this previously crashed if the messages had been returned to the main queue. This fix makes the query safer as well as handling missing messages better.
| * Quorum queue: return messages in orderkjnilsson2018-12-175-36/+60
| | | | | | | | | | | | | | | | | | Fixes bug that muddled up the checkout order when a consumer is cancelled with more than 32 messages checked out. Dialyzer fixes. [#162698673]
| * Bug fixeskjnilsson2018-12-172-23/+38
| | | | | | | | | | | | | | | | | | 1. rabbit_quorum_queue:update_metrics/2 used calls to remote processes. To avoid this blocking the ra server in a partition we now spawn a new process for this. 2. Due to a refactoring miss commands over the soft limit where never formatted successfully.
* | Merge pull request #1685 from rabbitmq/rabbitmq-server-1682Luke Bakken2018-12-171-1/+11
|\ \ | |/ |/| Take "true" case into consideration
| * Simplify to basically removing the pattern match that crashesLuke Bakken2018-12-141-15/+8
| |
| * Take "true" case into considerationLuke Bakken2018-12-141-3/+20
|/ | | | | | Fixes #1682 Call E() instead of crashing with badmatch, retry when queue is mirrored
* Merge pull request #1796 from rabbitmq/report-message-bytesKarl Nilsson2018-12-143-30/+165
|\ | | | | Report message bytes in quorum queue stats
| * Report message bytes in quorum queue statsDiana Corbacho2018-12-143-30/+165
|/ | | | [#161505138]
* Merge pull request #1801 from rabbitmq/qq-list-consumersArnaud Cogoluègnes2018-12-148-296/+480
|\ | | | | Implement consumer listing for quorum queues
| * fix rabbit_fifo SUITEkjnilsson2018-12-141-5/+7
| |
| * Implement consumer listing for quorum queueskjnilsson2018-12-148-292/+474
| | | | | | | | | | | | | | | | Refactor rabbit_fifo internal commands to use records instead of plain tuples to provide a little bit more compile time safety and make it easier to extend in the future. [#162584074]
* | Merge pull request #1800 from rabbitmq/qq-ghost-consumer-fixD Corbacho2018-12-143-49/+29
|\ \ | |/ | | Ensure quorum queue consumers are cleaned up
| * Ensure quorum queue consumers are cleaned upkjnilsson2018-12-123-49/+29
| | | | | | | | | | | | | | | | | | Fixes a bug where the consumer_created metrics table wasn't cleared when a consumer was cancelled. Also removing some injected handlers from rabbit_fifo [#162583758]
* | Merge pull request #1798 from rabbitmq/remove-unused-truncate-moduleMichael Klishin2018-12-122-197/+0
|\ \ | | | | | | Remove the unused truncate module
| * | Remove the unused truncate moduleLoïc Hoguin2018-12-112-197/+0
| |/ | | | | | | This kind of truncation is done automatically by lager now.
* | Merge pull request #1791 from rabbitmq/wal-roll-overKarl Nilsson2018-12-112-2/+103
|\ \ | |/ |/| Roll wal on memory alarm
| * Roll wal on memory alarmDiana Corbacho2018-12-052-2/+103
| | | | | | | | [#161408569]
* | Merge pull request #1792 from rabbitmq/qq-dlx-fixKarl Nilsson2018-12-101-3/+7
|\ \ | | | | | | Ignore error when dead letter exchange cannot be found
| * | Ignore error when dead letter exchange cannot be foundDiana Corbacho2018-12-061-2/+1
| | | | | | | | | | | | | | | Avoids swamping the log, same as classic queues [#162411672]
| * | Log a warning if dead letter exchange cannot be foundDiana Corbacho2018-12-061-3/+8
| |/ | | | | | | [#162411672]
* | rabbit_channel: Import `queue_fold()` from rabbit_miscJean-Sébastien Pédron2018-12-101-1/+7
| | | | | | | | | | | | ... and modify it to use `lqueue`. The copy in `rabbit_misc` assumes the use of regular `queue:queue()`.
* | Merge pull request #1795 from rabbitmq/rabbitmq-website-633Michael Klishin2018-12-073-1/+7
|\ \ | | | | | | Document new cli switches
| * | Add awk rule for new mandoc "Bd Bd-indent" classLuke Bakken2018-12-071-0/+1
| | |
| * | Document new cli switchesLuke Bakken2018-12-062-1/+6
| | | | | | | | | | | | | | | | | | Fixes rabbitmq/rabbitmq-website#633 Also includes minor fix for -detached argument
* | | Merge pull request #1794 from rabbitmq/rabbitmq-server-1783Michael Klishin2018-12-072-33/+81
|\ \ \ | | | | | | | | Implement node health check timeouts
| * | | Add code to enforce deadline when getting channel info items. Standardize ↵Luke Bakken2018-12-061-9/+54
| | | | | | | | | | | | | | | | return value from info gen_server handler
| * | | Replace a couple instances of queue with lqueueLuke Bakken2018-12-052-24/+27
| | |/ | |/|
* | | Add rabbit_fifo snapshot property testkjnilsson2018-12-074-74/+468
| | | | | | | | | | | | And fix various subtle bugs around snapshotting.
* | | Explain how man pages are generatedMichael Klishin2018-12-071-0/+17
| |/ |/| | | Per discussion with @lukebakken.
* | Update rabbitmq-components.mkMichael Klishin2018-12-061-6/+0
|/
* Merge pull request #1747 from rabbitmq/ranch_proxy_headerMichael Klishin2018-12-054-30/+34
|\ | | | | Use the built-in Ranch PROXY protocol support
| * Merge branch 'master' into ranch_proxy_headerMichael Klishin2018-12-054-14/+79
| |\ | |/ |/|
* | Merge pull request #1787 from rabbitmq/dialyze-qqMichael Klishin2018-12-054-14/+79
|\ \ | | | | | | Fix dialyzer warnings
| * | Minor improvements to test stabilityMichael Klishin2018-12-052-2/+13
| | | | | | | | | | | | Per discussion with @dcorbacho.
| * | Merge branch 'master' into dialyze-qqMichael Klishin2018-12-056-97/+347
| |\ \ | |/ / |/| |
| * | CompileMichael Klishin2018-12-051-1/+1
| | |
| * | Merge branch 'master' into dialyze-qqMichael Klishin2018-12-0511-43/+193
| |\ \ | | | | | | | | | | | | | | | | Conflicts: test/quorum_queue_SUITE.erl
| * \ \ Merge branch 'master' into dialyze-qqDiana Corbacho2018-12-047-50/+307
| |\ \ \
View Lorry Controller Status