summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #1950 from rabbitmq/rabbit-fifo-bugfixesKarl Nilsson2019-03-263-165/+545
|\ | | | | Rabbit fifo bug fixes
| * Disable test that cannot currently passkjnilsson2019-03-212-29/+25
| |
| * rabbit_fifo: propery tests for single active consumerkjnilsson2019-03-202-26/+324
| | | | | | | | | | | | | | To test send_msg ordering and ensure there never two active consumers at once. [#164691411]
| * rabbit_fifo: Ensure checkout is performedkjnilsson2019-03-182-29/+42
| | | | | | | | After a down command is processed
| * rabbit_fifo bugfixeskjnilsson2019-03-183-112/+185
| | | | | | | | | | | | | | Bugfixes around noconnect consumer handling as well as refactoring to make these kinds of errors less likely. [#164691411]
* | Merge branch 'masaki-furuta-toggle_disk_monitor'Michael Klishin2019-03-221-1/+14
|\ \
| * | Pattern match in function headsMichael Klishin2019-03-221-8/+8
| | |
| * | Merge branch 'toggle_disk_monitor' of ↵Michael Klishin2019-03-221-1/+14
| |\ \ |/ / / | | | | | | https://github.com/masaki-furuta/rabbitmq-server into masaki-furuta-toggle_disk_monitor
| * | Update rabbit_disk_monitor.erlMasaki Furuta2019-03-221-1/+0
| | | | | | | | | Remove unused default value for enabled.
| * | Debug: Applying patch to disable disk_monitor on the fly by rabbitctl eval.Masaki Furuta2019-03-221-1/+15
| | | | | | | | | | | | | | | | | | | | | To disbale: rabbitmqctl eval 'rabbit_disk_monitor:set_enabled(false).' To re-enable: rabbitmqctl eval 'rabbit_disk_monitor:set_enabled(true).'
* | | Merge pull request #1953 from spring-operator/polish-urls-apache-license-masterMichael Klishin2019-03-222-2/+2
|\ \ \ | | | | | | | | URL Cleanup
| * | | URL CleanupSpring Operator2019-03-212-2/+2
| |/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener). # Fixed URLs ## Fixed Success These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended. * [ ] http://www.apache.org/licenses/LICENSE-2.0 with 2 occurrences migrated to: https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).
* | | Merge pull request #1917 from rabbitmq/rabbitmq-server-1906Arnaud Cogoluègnes2019-03-221-7/+8
|\ \ \ | |/ / |/| | Quorum Queues: resend messages if first batch is lost
| * | Merge branch 'master' into rabbitmq-server-1906Michael Klishin2019-03-159-50/+108
| |\ \
| * | | Explain why last_applied is initialised to -1Diana Corbacho2019-03-151-0/+3
| | | | | | | | | | | | | | | | [#164375485]
| * | | Resend messages if first messages are lostDiana Corbacho2019-03-151-7/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | last_applied is now initialised to -1 and resend always happens if we have an out of order sequence rabbitmq-server #1906 [#164375485]
* | | | Quorum queue: make leader repair more defensivekjnilsson2019-03-201-4/+5
| | | | | | | | | | | | | | | | | | | | | | | | | | | | By moving it into the process spawned every tick interval to update metrics and repair the leader record. Fixes sporadic test failures in rabbit_fifi_int_SUITE.
* | | | Merge pull request #1949 from spring-operator/polish-urls-remaining-masterMichael Klishin2019-03-20239-370/+370
|\ \ \ \ | | | | | | | | | | URL Cleanup
| * | | | URL CleanupSpring Operator2019-03-20239-370/+370
|/ / / / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener). # HTTP URLs that Could Not Be Fixed These URLs were unable to be fixed. Please review them to see if they can be manually resolved. * http://alvaro-videla.com/2013/09/rabbitmq-internals-credit-flow-for-erlang-processes.html (200) with 1 occurrences could not be migrated: ([https](https://alvaro-videla.com/2013/09/rabbitmq-internals-credit-flow-for-erlang-processes.html) result SSLHandshakeException). * http://blog.listincomprehension.com/search/label/procket (200) with 2 occurrences could not be migrated: ([https](https://blog.listincomprehension.com/search/label/procket) result ClosedChannelException). * http://dozzie.jarowit.net/trac/wiki/TOML (200) with 2 occurrences could not be migrated: ([https](https://dozzie.jarowit.net/trac/wiki/TOML) result SSLHandshakeException). * http://dozzie.jarowit.net/trac/wiki/subproc (200) with 2 occurrences could not be migrated: ([https](https://dozzie.jarowit.net/trac/wiki/subproc) result SSLHandshakeException). * http://e2project.org (200) with 2 occurrences could not be migrated: ([https](https://e2project.org) result AnnotatedConnectException). * http://erlang.org/doc/man/kernel_app.html (200) with 2 occurrences could not be migrated: ([https](https://erlang.org/doc/man/kernel_app.html) result ConnectTimeoutException). * http://erlang.org/pipermail/erlang-questions/2012-September/069320.html (200) with 1 occurrences could not be migrated: ([https](https://erlang.org/pipermail/erlang-questions/2012-September/069320.html) result ConnectTimeoutException). * http://nitrogenproject.com/ (200) with 4 occurrences could not be migrated: ([https](https://nitrogenproject.com/) result ConnectTimeoutException). * http://proper.softlab.ntua.gr (200) with 2 occurrences could not be migrated: ([https](https://proper.softlab.ntua.gr) result SSLHandshakeException). * http://proper.softlab.ntua.gr/ (200) with 1 occurrences could not be migrated: ([https](https://proper.softlab.ntua.gr/) result SSLHandshakeException). * http://rubybunny.info (200) with 1 occurrences could not be migrated: ([https](https://rubybunny.info) result AnnotatedConnectException). * http://yaws.hyber.org (200) with 2 occurrences could not be migrated: ([https](https://yaws.hyber.org) result AnnotatedConnectException). * http://choven.ca (503) with 2 occurrences could not be migrated: ([https](https://choven.ca) result ConnectTimeoutException). # Fixed URLs ## Fixed But Review Recommended These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended. * http://fixprotocol.org/ (301) with 1 occurrences migrated to: https://fixtrading.org ([https](https://fixprotocol.org/) result SSLHandshakeException). * http://erldb.org (UnknownHostException) with 1 occurrences migrated to: https://erldb.org ([https](https://erldb.org) result UnknownHostException). * http://www.erlang.org/cgi-bin/ezmlm-cgi?2:mss:1569 (404) with 1 occurrences migrated to: https://www.erlang.org/cgi-bin/ezmlm-cgi?2:mss:1569 ([https](https://www.erlang.org/cgi-bin/ezmlm-cgi?2:mss:1569) result 404). * http://www.rabbitmq.com/quorum-queues.html (404) with 1 occurrences migrated to: https://www.rabbitmq.com/quorum-queues.html ([https](https://www.rabbitmq.com/quorum-queues.html) result 404). ## Fixed Success These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended. * http://cloudi.org/ with 27 occurrences migrated to: https://cloudi.org/ ([https](https://cloudi.org/) result 200). * http://erlware.org/ with 1 occurrences migrated to: https://erlware.org/ ([https](https://erlware.org/) result 200). * http://inaka.github.io/cowboy-trails/ with 1 occurrences migrated to: https://inaka.github.io/cowboy-trails/ ([https](https://inaka.github.io/cowboy-trails/) result 200). * http://ninenines.eu with 6 occurrences migrated to: https://ninenines.eu ([https](https://ninenines.eu) result 200). * http://pivotal.io with 1 occurrences migrated to: https://pivotal.io ([https](https://pivotal.io) result 200). * http://pubs.opengroup.org/onlinepubs/009695399/utilities/kill.html with 1 occurrences migrated to: https://pubs.opengroup.org/onlinepubs/009695399/utilities/kill.html ([https](https://pubs.opengroup.org/onlinepubs/009695399/utilities/kill.html) result 200). * http://www.actordb.com/ with 2 occurrences migrated to: https://www.actordb.com/ ([https](https://www.actordb.com/) result 200). * http://www.cs.kent.ac.uk/projects/wrangler/Home.html with 1 occurrences migrated to: https://www.cs.kent.ac.uk/projects/wrangler/Home.html ([https](https://www.cs.kent.ac.uk/projects/wrangler/Home.html) result 200). * http://www.erlang.org/ with 1 occurrences migrated to: https://www.erlang.org/ ([https](https://www.erlang.org/) result 200). * http://www.rabbitmq.com/access-control.html with 3 occurrences migrated to: https://www.rabbitmq.com/access-control.html ([https](https://www.rabbitmq.com/access-control.html) result 200). * http://www.rabbitmq.com/authentication.html with 2 occurrences migrated to: https://www.rabbitmq.com/authentication.html ([https](https://www.rabbitmq.com/authentication.html) result 200). * http://www.rabbitmq.com/clustering.html with 5 occurrences migrated to: https://www.rabbitmq.com/clustering.html ([https](https://www.rabbitmq.com/clustering.html) result 200). * http://www.rabbitmq.com/configure.html with 2 occurrences migrated to: https://www.rabbitmq.com/configure.html ([https](https://www.rabbitmq.com/configure.html) result 200). * http://www.rabbitmq.com/confirms.html with 1 occurrences migrated to: https://www.rabbitmq.com/confirms.html ([https](https://www.rabbitmq.com/confirms.html) result 200). * http://www.rabbitmq.com/dlx.html with 1 occurrences migrated to: https://www.rabbitmq.com/dlx.html ([https](https://www.rabbitmq.com/dlx.html) result 200). * http://www.rabbitmq.com/documentation.html with 1 occurrences migrated to: https://www.rabbitmq.com/documentation.html ([https](https://www.rabbitmq.com/documentation.html) result 200). * http://www.rabbitmq.com/download.html with 2 occurrences migrated to: https://www.rabbitmq.com/download.html ([https](https://www.rabbitmq.com/download.html) result 200). * http://www.rabbitmq.com/heartbeats.html with 1 occurrences migrated to: https://www.rabbitmq.com/heartbeats.html ([https](https://www.rabbitmq.com/heartbeats.html) result 200). * http://www.rabbitmq.com/lazy-queues.html with 1 occurrences migrated to: https://www.rabbitmq.com/lazy-queues.html ([https](https://www.rabbitmq.com/lazy-queues.html) result 200). * http://www.rabbitmq.com/ldap.html with 4 occurrences migrated to: https://www.rabbitmq.com/ldap.html ([https](https://www.rabbitmq.com/ldap.html) result 200). * http://www.rabbitmq.com/management.html with 6 occurrences migrated to: https://www.rabbitmq.com/management.html ([https](https://www.rabbitmq.com/management.html) result 200). * http://www.rabbitmq.com/memory-use.html with 3 occurrences migrated to: https://www.rabbitmq.com/memory-use.html ([https](https://www.rabbitmq.com/memory-use.html) result 200). * http://www.rabbitmq.com/memory.html with 2 occurrences migrated to: https://www.rabbitmq.com/memory.html ([https](https://www.rabbitmq.com/memory.html) result 200). * http://www.rabbitmq.com/monitoring.html with 1 occurrences migrated to: https://www.rabbitmq.com/monitoring.html ([https](https://www.rabbitmq.com/monitoring.html) result 200). * http://www.rabbitmq.com/nettick.html with 2 occurrences migrated to: https://www.rabbitmq.com/nettick.html ([https](https://www.rabbitmq.com/nettick.html) result 200). * http://www.rabbitmq.com/networking.html with 7 occurrences migrated to: https://www.rabbitmq.com/networking.html ([https](https://www.rabbitmq.com/networking.html) result 200). * http://www.rabbitmq.com/partitions.html with 2 occurrences migrated to: https://www.rabbitmq.com/partitions.html ([https](https://www.rabbitmq.com/partitions.html) result 200). * http://www.rabbitmq.com/persistence-conf.html with 3 occurrences migrated to: https://www.rabbitmq.com/persistence-conf.html ([https](https://www.rabbitmq.com/persistence-conf.html) result 200). * http://www.rabbitmq.com/plugins.html with 1 occurrences migrated to: https://www.rabbitmq.com/plugins.html ([https](https://www.rabbitmq.com/plugins.html) result 200). * http://www.rabbitmq.com/previous.html with 1 occurrences migrated to: https://www.rabbitmq.com/previous.html ([https](https://www.rabbitmq.com/previous.html) result 200). * http://www.rabbitmq.com/shovel.html with 2 occurrences migrated to: https://www.rabbitmq.com/shovel.html ([https](https://www.rabbitmq.com/shovel.html) result 200). * http://www.rabbitmq.com/ssl.html with 2 occurrences migrated to: https://www.rabbitmq.com/ssl.html ([https](https://www.rabbitmq.com/ssl.html) result 200). * http://www.rabbitmq.com/stomp.html with 1 occurrences migrated to: https://www.rabbitmq.com/stomp.html ([https](https://www.rabbitmq.com/stomp.html) result 200). * http://www.rebar3.org with 1 occurrences migrated to: https://www.rebar3.org ([https](https://www.rebar3.org) result 200). * http://contributor-covenant.org with 1 occurrences migrated to: https://contributor-covenant.org ([https](https://contributor-covenant.org) result 301). * http://contributor-covenant.org/version/1/3/0/ with 1 occurrences migrated to: https://contributor-covenant.org/version/1/3/0/ ([https](https://contributor-covenant.org/version/1/3/0/) result 301). * http://inaka.github.com/apns4erl with 1 occurrences migrated to: https://inaka.github.com/apns4erl ([https](https://inaka.github.com/apns4erl) result 301). * http://inaka.github.com/edis/ with 1 occurrences migrated to: https://inaka.github.com/edis/ ([https](https://inaka.github.com/edis/) result 301). * http://lasp-lang.org/ with 1 occurrences migrated to: https://lasp-lang.org/ ([https](https://lasp-lang.org/) result 301). * http://rabbitmq.com//cluster-formation.html with 1 occurrences migrated to: https://rabbitmq.com//cluster-formation.html ([https](https://rabbitmq.com//cluster-formation.html) result 301). * http://rabbitmq.com/access-control.html with 4 occurrences migrated to: https://rabbitmq.com/access-control.html ([https](https://rabbitmq.com/access-control.html) result 301). * http://rabbitmq.com/authentication.html with 2 occurrences migrated to: https://rabbitmq.com/authentication.html ([https](https://rabbitmq.com/authentication.html) result 301). * http://rabbitmq.com/clustering.html with 1 occurrences migrated to: https://rabbitmq.com/clustering.html ([https](https://rabbitmq.com/clustering.html) result 301). * http://rabbitmq.com/configure.html with 1 occurrences migrated to: https://rabbitmq.com/configure.html ([https](https://rabbitmq.com/configure.html) result 301). * http://rabbitmq.com/documentation.html with 2 occurrences migrated to: https://rabbitmq.com/documentation.html ([https](https://rabbitmq.com/documentation.html) result 301). * http://rabbitmq.com/heartbeats.html with 1 occurrences migrated to: https://rabbitmq.com/heartbeats.html ([https](https://rabbitmq.com/heartbeats.html) result 301). * http://rabbitmq.com/lazy-queues.html with 1 occurrences migrated to: https://rabbitmq.com/lazy-queues.html ([https](https://rabbitmq.com/lazy-queues.html) result 301). * http://rabbitmq.com/ldap.html with 3 occurrences migrated to: https://rabbitmq.com/ldap.html ([https](https://rabbitmq.com/ldap.html) result 301). * http://rabbitmq.com/logging.html with 1 occurrences migrated to: https://rabbitmq.com/logging.html ([https](https://rabbitmq.com/logging.html) result 301). * http://rabbitmq.com/management.html with 5 occurrences migrated to: https://rabbitmq.com/management.html ([https](https://rabbitmq.com/management.html) result 301). * http://rabbitmq.com/memory.html with 1 occurrences migrated to: https://rabbitmq.com/memory.html ([https](https://rabbitmq.com/memory.html) result 301). * http://rabbitmq.com/networking.html with 3 occurrences migrated to: https://rabbitmq.com/networking.html ([https](https://rabbitmq.com/networking.html) result 301). * http://rabbitmq.com/persistence-conf.html with 1 occurrences migrated to: https://rabbitmq.com/persistence-conf.html ([https](https://rabbitmq.com/persistence-conf.html) result 301). * http://rabbitmq.com/plugins.html with 1 occurrences migrated to: https://rabbitmq.com/plugins.html ([https](https://rabbitmq.com/plugins.html) result 301). * http://rabbitmq.com/shovel.html with 1 occurrences migrated to: https://rabbitmq.com/shovel.html ([https](https://rabbitmq.com/shovel.html) result 301). * http://rabbitmq.com/ssl.html with 1 occurrences migrated to: https://rabbitmq.com/ssl.html ([https](https://rabbitmq.com/ssl.html) result 301). * http://rabbitmq.com/stomp.html with 1 occurrences migrated to: https://rabbitmq.com/stomp.html ([https](https://rabbitmq.com/stomp.html) result 301). * http://saleyn.github.com/erlexec with 1 occurrences migrated to: https://saleyn.github.com/erlexec ([https](https://saleyn.github.com/erlexec) result 301). * http://www.erlang.org/doc/man/inet.html with 2 occurrences migrated to: https://www.erlang.org/doc/man/inet.html ([https](https://www.erlang.org/doc/man/inet.html) result 301). * http://www.erlang.org/doc/man/sys.html with 1 occurrences migrated to: https://www.erlang.org/doc/man/sys.html ([https](https://www.erlang.org/doc/man/sys.html) result 301). * http://www.mozilla.org/MPL/ with 228 occurrences migrated to: https://www.mozilla.org/MPL/ ([https](https://www.mozilla.org/MPL/) result 301). * http://zhongwencool.github.io/observer_cli with 1 occurrences migrated to: https://zhongwencool.github.io/observer_cli ([https](https://zhongwencool.github.io/observer_cli) result 301).
* | | | Travis: use Erlang 21.3Michael Klishin2019-03-201-1/+1
| | | |
* | | | rabbit_lager: Multiply high watermark on startup as wellJean-Sébastien Pédron2019-03-181-1/+26
| |_|/ |/| | | | | | | | | | | | | | | | | | | | ... if the log level is set to `debug` in the configuration. This allows us to revert commit rabbitmq/rabbitmq-common@c04944235b. References #1912.
* | | Merge pull request #1918 from rabbitmq/list-queue-typeMichael Klishin2019-03-183-0/+3
|\ \ \ | |_|/ |/| | Add queue type to queue listing commands
| * | Add queue type to queue listing commandsDiana Corbacho2019-03-153-0/+3
| | | | | | | | | | | | [#163984879]
* | | Type spec: amqqueue:get_policy/1 returns a proplistMichael Klishin2019-03-151-1/+1
|/ / | | | | | | Spotted while dialyzing Federation plugin.
* | Update rabbitmq-components.mkMichael Klishin2019-03-151-1/+1
| |
* | Update rabbitmq-components.mkMichael Klishin2019-03-151-1/+1
| |
* | Merge pull request #1912 from ↵Michael Klishin2019-03-151-13/+22
|\ \ | | | | | | | | | | | | rabbitmq/bump-lager-high-watermark-if-level-is-debug rabbit_lager: Multiply high watermark by 100 when log level is debug
| * | Add check for integer valueLuke Bakken2019-03-131-1/+1
| | |
| * | rabbit_lager: Multiply high watermark by 100 when log level is debugJean-Sébastien Pédron2019-03-131-12/+21
| |/ | | | | | | Otherwise debug messages are quickly dropped by Lager.
* | Merge pull request #1913 from rabbitmq/rabbitmq-server-1869Michael Klishin2019-03-153-27/+42
|\ \ | | | | | | Move TCP and TLS listener startup to the last boot step "stage"
| * | Log boot steps as they runMichael Klishin2019-03-131-5/+12
| | |
| * | Treat rabbit_direct boot step as enabling listenersMichael Klishin2019-03-131-6/+6
| | | | | | | | | | | | | | | | | | | | | Since it makes direct Erlang client connections possible. References #1689.
| * | Undo recovery step dependencyMichael Klishin2019-03-131-1/+1
| | | | | | | | | | | | | | | Requires more extensive review and out of scope for #1869.
| * | Start TCP and TLS listeners later in boot processMichael Klishin2019-03-131-17/+26
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | See #1869 for background. This makes listener startup and peer notification to be some of the last boot steps. This way client operations on a node that's not 100% initialised are less likely. Since some parts of boot process happen concurrently, without coordinating all of them with listener startup this is not something that can be guaranteed. Moving listener startup to a later stage reduces the probability of clients attempting operations on a booting node.
| * | Drive-by change: cosmeticsMichael Klishin2019-03-131-2/+1
| |/
* | Fix snapshot bug in rabbit_fifokjnilsson2019-03-142-5/+31
| | | | | | | | | | | | The waiting_consumers were not being "dehydrated" causing snapshots to potentially contain message bodies causing occasional test failures in the snapshots property tests.
* | Merge branch 'thedrow-patch-1'Michael Klishin2019-03-141-2/+10
|\ \ | |/ |/| | | Closes #1914.
| * Simplify further with a macro, suggested by @dumbbellMichael Klishin2019-03-141-2/+4
| |
| * rabbit_auth_mechanism_amqplain: refactor, improve error messageMichael Klishin2019-03-141-11/+8
| |
| * Allow shortstr in AMQPlain authentication methodOmer Katz2019-03-141-0/+9
|/ | | Fixes #1914.
* Merge pull request #1910 from spring-operator/polish-urls-build-masterMichael Klishin2019-03-126-6/+6
|\ | | | | URL Cleanup
| * URL CleanupSpring Operator2019-03-126-6/+6
|/ | | | | | | | | | | | This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener). # Fixed URLs ## Fixed Success These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended. * http://www.mozilla.org/MPL/ migrated to: https://www.mozilla.org/MPL/ ([https](https://www.mozilla.org/MPL/) result 301).
* rabbit_fifo_prop_SUITE: `fake_pid` was removedv3.8.0-beta.3Jean-Sébastien Pédron2019-03-041-2/+1
| | | | ... in commit 3b0adfda40edf59496ff9f6d994a11c27971a3f5.
* Merge pull request #1903 from rabbitmq/single-active-noconnectionMichael Klishin2019-03-018-199/+438
|\ | | | | rabbit_fifo: change single active consumer on noconnection
| * Remove a helper test erlc considers unused, per discussion with @kjnilssonMichael Klishin2019-03-011-11/+0
| |
| * Emit inactive when no consumer can be activatedkjnilsson2019-03-012-2/+2
| |
| * Tweak qourum queue tick interval for testskjnilsson2019-03-013-5/+10
| | | | | | | | | | | | | | | | | | As some tests use metrics to assert on and quorum queues only emit metrics every 5s by default. This change takes it down to 1s for selected suites. It also introduces a new `quorum_tick_interval` application parameter to set this interval.
| * Merge branch 'master' into single-active-noconnectionMichael Klishin2019-02-282-7/+23
| |\
| * | Ensure waiting consumers can receive creditkjnilsson2019-02-282-2/+50
| | | | | | | | | | | | | | | | | | | | | Else they may never be able to do any processing when they get promoted to active and AMQP 1.0 is used. [#164135123]
| * | rabbit_fifo: cancel should not remove single active consumerkjnilsson2019-02-273-24/+88
| | | | | | | | | | | | | | | | | | | | | | | | This change keeps a cancelled single active consumer in the consuemrs map but with the cancelled status allowing another consumer to take over as the active one. [#164135123]
View Lorry Controller Status