summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Roll wal on memory alarmDiana Corbacho2018-12-052-2/+103
| | | | [#161408569]
* 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
| |\ \ \
| * | | | Give valid cluster name to rabbit_fifo_clientDiana Corbacho2018-12-041-2/+4
| | | | |
| * | | | Implement delete_immediately_by_resourceDiana Corbacho2018-12-033-8/+65
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | delete_immediately doesn't work for qq as we cannot easily retrieve resource name from qpid. Instead, delete_immediately_by_resource receives a resource record which should make it easier for both users and developers. Usage: `rabbitmqctl eval 'rabbit_amqqueue:delete_immediately([rabbit_misc:r(<<"VHOST_NAME">>, queue, <<"QUEUE_NAME">>)]).'`
| * | | | Use ra nodes to intialise rabbit_fifo_clientDiana Corbacho2018-12-031-1/+1
| | | | |
| * | | | Fix rabbit_quorum_queue:status type specDiana Corbacho2018-12-031-1/+1
| | | | |
| | | | * Merge branch 'master' into ranch_proxy_headerMichael Klishin2018-12-0510-133/+500
| | | | |\ | |_|_|_|/ |/| | | |
* | | | | Fix test to account for new eventkjnilsson2018-12-051-4/+10
| | | | |
* | | | | Merge pull request #1782 from rabbitmq/qq-confirm-availabilityD Corbacho2018-12-055-93/+337
|\ \ \ \ \ | |_|_|/ / |/| | | | Quorum queue confirm availability
| * | | | rabbit_channel: revert changes to IS_QUORUM macrokjnilsson2018-12-041-1/+1
| | | | |
| * | | | uncomment commented gc callkjnilsson2018-12-041-1/+1
| | | | |
| * | | | Better handle changing quorum queue leaderskjnilsson2018-12-045-64/+139
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | All maps that track queues inside the channel should use the queue name atom rather than the server id as they key so that leader changes don't impact this tracking.
| * | | | Notify all enqueuers and consuers on leader changekjnilsson2018-12-042-26/+89
| | | | | | | | | | | | | | | | | | | | | | | | | This should ensure liveness and avoid missed confirms when the leader changes.
| * | | | rabbit_fifo: ensure credit is regainedkjnilsson2018-12-041-19/+41
| | | | | | | | | | | | | | | | | | | | When returning a $prefix_msg
| * | | | Use correct key for recording quorum queue confirmskjnilsson2018-12-045-22/+106
| | | | |
* | | | | Merge pull request #1774 from noxdafox/masterMichael Klishin2018-12-052-32/+37
|\ \ \ \ \ | |/ / / / |/| | | | RFC rabbit_amqqueue_process: improve message duplicates handling
| * | | | Merge branch 'master' of github.com:rabbitmq/rabbitmq-serverMatteo Cafasso2018-11-2447-423/+6699
| |\ \ \ \
| * | | | | rabbit_mirror_queue_master: is_duplicate drop duplicate messagesMatteo Cafasso2018-11-241-3/+3
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Inform the amqqueue process to drop a duplicate message if so. Signed-off-by: Matteo Cafasso <noxdafox@gmail.com>
| * | | | | rabbit_amqqueue_process: handle is_duplicate instructionsMatteo Cafasso2018-11-231-29/+34
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | The `is_duplicate` callback can signal the amqqueue process that the message is a duplicate and suggests whether to just ignore it or to reject it. This enables the `rabbit_backing_queue` implementations to notify a publisher that the message is deemed a duplicate. Signed-off-by: Matteo Cafasso <noxdafox@gmail.com>
* | | | | | Merge pull request #1788 from rabbitmq/delivery-count-headerKarl Nilsson2018-12-044-4/+116
|\ \ \ \ \ \ | | | | | | | | | | | | | | Include redelivery counts for quorum queues
| * | | | | | Rename x-redelivery-count to x-delivery-count to align with AMQP1.0Diana Corbacho2018-12-043-4/+4
| | | | | | | | | | | | | | | | | | | | | | | | | | | | [#161057187]
| * | | | | | Add x-redelivery-count header to quorum messagesDiana Corbacho2018-11-294-4/+116
| | |_|/ / / | |/| | | | | | | | | | | | | | | | [#161057187]
| | | | | * Use the built-in Ranch PROXY protocol supportLoïc Hoguin2018-12-044-30/+34
| |_|_|_|/ |/| | | |
* | | | | Contributors are welcome on the mailing listMichael Klishin2018-12-041-0/+2
| | | | |
* | | | | README updatesMichael Klishin2018-12-041-3/+5
| | | | |
* | | | | Merge pull request #1785 from rabbitmq/rabbitmq-server-1784Michael Klishin2018-12-033-0/+34
|\ \ \ \ \ | |_|_|_|/ |/| | | | Make it possible to configure kernel.inet_dist_listen_{min,max} via new style config
| * | | | Update rabbitmq.conf.example for #1784Michael Klishin2018-12-021-0/+9
| | | | |
| * | | | Make it possible to configure kernel.inet_dist_listen_{min,max} via new ↵Michael Klishin2018-12-022-0/+25
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | style config Closes #1784.
* | | | | Optimise quorum_queue SUITEkjnilsson2018-12-032-6/+10
| | | | | | | | | | | | | | | | | | | | | | | | | By reducing net_ticktime in the suite and base the hardcoded queue.delete on net_ticktime.
* | | | | Merge pull request #1764 from rabbitmq/qq-dlx-policyKarl Nilsson2018-12-035-25/+72
|\ \ \ \ \ | | | | | | | | | | | | Support dlx policy changes in quorum queues
| * \ \ \ \ Merge branch 'master' into qq-dlx-policyDiana Corbacho2018-11-2210-202/+121
| |\ \ \ \ \
| * | | | | | Rename ra_machine_state to ra_machine_configDiana Corbacho2018-11-081-3/+3
| | | | | | | | | | | | | | | | | | | | | | | | | | | | [#161247406]
| * | | | | | Support dlx policy changes in quorum queuesDiana Corbacho2018-11-075-25/+72
| | | | | | | | | | | | | | | | | | | | | | | | | | | | [#161247406]
* | | | | | | Merge pull request #1772 from rabbitmq/memory-breakdown-qqKarl Nilsson2018-12-031-4/+12
|\ \ \ \ \ \ \ | | | | | | | | | | | | | | | | Report quorum queues memory usage in rabbit_vm
| * | | | | | | Add comment about not all ra servers being queueskjnilsson2018-12-031-0/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | To remind us to filter this in the future.
| * | | | | | | Report quorum queues memory usage in rabbit_vmDiana Corbacho2018-11-211-4/+10
| | |/ / / / / | |/| | | | | | | | | | | | | | | | | | | [#161505148]
* | | | | | | Merge pull request #1771 from rabbitmq/return-unack-any-down-reasonKarl Nilsson2018-12-032-15/+213
|\ \ \ \ \ \ \ | |_|_|/ / / / |/| | | | | | Return delivered but unack messages to the queue for noconnection reason
| * | | | | | remove unused variablekjnilsson2018-12-031-1/+1
| | | | | | |
| * | | | | | Ensure delivery doesn't happen when consumers are suspected downDiana Corbacho2018-12-032-8/+184
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Testcases for unack messages returned to queue on noconnection [#161679638]
| * | | | | | Return delivered but unack messages to the queeu for noconnection reasonDiana Corbacho2018-12-031-8/+30
| | |_|_|_|/ | |/| | | | | | | | | | | | | | | | [#161679638]
* | | | | | Update rabbitmq-components.mkJean-Sébastien Pédron2018-11-301-2/+2
| |_|_|/ / |/| | | |
* | | | | Merge pull request #1776 from rabbitmq/rabbitmq-cli-276Michael Klishin2018-11-291-1/+29
|\ \ \ \ \ | | | | | | | | | | | | Add function to set log level at runtime
| * | | | | Add method to set log level at runtimeLuke Bakken2018-11-271-1/+29
| |/ / / / | | | | | | | | | | | | | | | | | | | | | | | | | Part of rabbitmq/rabbitmq-cli#276 `rabbit_lager:set_log_level` takes a log level as its only argument and will update all sinks and handlers to the new level
View Lorry Controller Status