summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* rabbit_variable_queue: Add logging to follow a new leadlrb-diagnose-file-handle-cache-issueJean-Sébastien Pédron2020-10-301-0/+4
|
* rabbit_msg_store diagnosis: argh gotta run the whole thing apparentlyLuke Bakken2020-10-292-2/+2
|
* rabbit_msg_store diagnosis: run more tests but not the entire suiteLuke Bakken2020-10-292-2/+2
|
* rabbit_msg_store diagnosis: add logging to try and determine when stale ↵Luke Bakken2020-10-293-7/+15
| | | | CState may be used. Try only running t=variable_queue_default:variable_queue_fold
* rabbit_msg_store: Log exception where the code may loop with stale stateJean-Sébastien Pédron2020-10-291-10/+8
|
* file_handle_cache diagnosis: re-throw exception using same classLuke Bakken2020-10-281-3/+3
|
* rabbit_msg_store: Try to understand if the code throws a badargJean-Sébastien Pédron2020-10-281-3/+9
| | | | ... and where it could come from.
* handle undefined caseLuke Bakken2020-10-281-0/+2
|
* Run entire backing_queue suiteLuke Bakken2020-10-282-2/+2
|
* Revert "DO NOT MERGE"Luke Bakken2020-10-281-0/+233
| | | | This reverts commit 889397deae7bd62abdc6fa7c81843dfb87e2c557.
* Limit tests that are runLuke Bakken2020-10-281-1/+1
|
* No need for app env varLuke Bakken2020-10-281-6/+0
|
* DO NOT MERGEJean-Sébastien Pédron2020-10-282-18423/+0
| | | | | Only keep `backing_queue_SUITE` with Erlang 22.3 to try to reproduce the problem.
* Enable FHC debug logLuke Bakken2020-10-281-0/+6
|
* Improved wordingMichael Klishin2020-10-271-2/+3
| | | | a drive-by change.
* Merge pull request #2481 from ↵Arnaud Cogoluègnes2020-10-232-2/+33
|\ | | | | | | | | rabbitmq/add-external-connections-for-refresh-event Add rabbit_non_amqp_connections process group
| * Rename process group to non_amqp_connectionArnaud Cogoluègnes2020-10-232-18/+18
| |
| * Add comments on force_event_refresh handlingadd-external-connections-for-refresh-eventArnaud Cogoluègnes2020-10-231-0/+4
| |
| * Add rabbit_external_connections process groupArnaud Cogoluègnes2020-10-232-2/+29
|/ | | | | | | | | | | | | This commit allows to propagate the force_event_refresh event to non-AMQP connections. This way other types of connections can be notified of the management plugin activation and start emitting statistics. This will be used for now by connections from the stream plugin. The existing rabbit_connections process group cannot be re-used in this case as it is used by the list_connections CLI command, and we do not want non-AMQP connections to show up in the output.
* Merge pull request #2475 from rabbitmq/queue-type-info-keysArnaud Cogoluègnes2020-10-226-28/+35
|\ | | | | Refactor info queues on queue types
| * Merge branch 'master' into queue-type-info-keysqueue-type-info-keysArnaud Cogoluègnes2020-10-2216-153/+291
| |\ | |/ |/|
* | Merge pull request #2471 from rabbitmq/stream-queue-leader-locatorArnaud Cogoluègnes2020-10-215-8/+262
|\ \ | | | | | | Stream queue leader locator
| * | Fix conflictstream-queue-leader-locatorArnaud Cogoluègnes2020-10-211-8/+0
| | |
| * | Merge branch 'master' into stream-queue-leader-locatorArnaud Cogoluègnes2020-10-2122-190/+98
| |\ \ | | | | | | | | | | | | | | | | Conflicts: test/rabbit_stream_queue_SUITE.erl
| * | | Use stream ID hash to pick "random" leaderstream-queue-leader-locator-with-hashArnaud Cogoluègnes2020-10-192-10/+7
| | | |
| * | | Use stream queue name hash to choose leaderArnaud Cogoluègnes2020-10-192-15/+22
| | | |
| * | | Stream queue-leader-locator argument and policydcorbacho2020-10-155-10/+266
| | | | | | | | | | | | | | | | Options: client-local, random, least-leaders
* | | | Update rabbitmq-components.mkMichael Klishin2020-10-211-2/+2
| |/ / |/| |
* | | Merge pull request #2478 from rabbitmq/rabbitmq-server-2473Luke Bakken2020-10-204-29/+0
|\ \ \ | | | | | | | | Remove all code related to RABBITMQ_IO_THREAD_POOL_SIZE
| * | | Remove all code related to RABBITMQ_IO_THREAD_POOL_SIZErabbitmq-server-2473Luke Bakken2020-10-204-29/+0
|/ / / | | | | | | | | | Fixes #2473
* | | rabbitmqctl(8): remove deprecated node_health_checkMichael Klishin2020-10-201-12/+0
| | | | | | | | | | | | | | | It's been deprecated for close to six months and already removed from some other docs.
* | | Merge pull request #2477 from rabbitmq/remove-arguments-validationMichael Klishin2020-10-203-100/+0
|\ \ \ | | | | | | | | Remove queue arguments validation
| * | | Remove queue arguments validationremove-arguments-validationdcorbacho2020-10-203-100/+0
|/ / / | | | | | | | | | Strict validation breaks plugins that might use any random queue argument
* | | Squash compiler warningsMichael Klishin2020-10-201-2/+2
| | |
* | | Merge pull request #2476 from rabbitmq/rabbitmq-server-2474Michael Klishin2020-10-201-0/+23
|\ \ \ | | | | | | | | Stop local quorum queue followers after transferring leadership
| * | | Stop local quorum queue followers after transferring leadershiprabbitmq-server-2474Michael Klishin2020-10-191-0/+23
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This way the shutdown of a node that's been put into maintenance mode won't have any further effects on the quorum (or rather, the effects will be "frontloaded" which is the goal of maintenance mode). Closes #2474.
* | | | Add missing consumer args to queue type capabilitieskjnilsson2020-10-192-2/+4
|/ / / | | | | | | | | | | | | | | | Both classic and quorum queues were missing x-credit which is used by the AMQP 1.0 implemention. Also classic queues were missing x-priority for consumer priority support.
| | * Refactor info queues on queue typesdcorbacho2020-10-196-28/+35
| |/ |/| | | | | Allow each queue type to have its own keys or return '' for unknown keys
* | Use named queues for single_active_consumer testkjnilsson2020-10-161-2/+5
| |
* | Merge pull request #2467 from rabbitmq/stream-initial-cluster-sizeArnaud Cogoluègnes2020-10-163-6/+71
|\ \ | |/ | | Stream initial cluster size
| * Select initial cluster size on stream queue declarationstream-initial-cluster-sizedcorbacho2020-10-123-6/+71
| |
* | Add missing classic queue capabilitykjnilsson2020-10-161-1/+1
| | | | | | | | x-queue-master-locator was missing from classic queue args.
* | Merge pull request #2466 from rabbitmq/rabbitmq-server-2296Arnaud Cogoluègnes2020-10-169-70/+106
|\ \ | |/ | | Prevent quorum and stream queues from being server-named
| * Disable server-named queues for quorum and stream queuesrabbitmq-server-2296dcorbacho2020-10-098-16/+56
| |
| * Refactor: queue capabilities on queue typesdcorbacho2020-10-095-67/+63
| | | | | | | | | | | | | | Queue implementations can delegate the responsibility of validating policies, arguments and other capabilities to `rabbit_queue_type`, they only need to declare a 'capabilities' map that provides the list of supported capabilities.
* | Update README.mdMichael Klishin2020-10-161-1/+1
| |
* | rabbit_stream_queue_SUITE: Give more time for expired messages to go awayJean-Sébastien Pédron2020-10-151-0/+2
| | | | | | | | | | | | | | | | | | | | The testcase is time-sensitive: it may be possible that the expired messages are not all dropped at the time we consume the queue to acknowledge they are gone. We give them 5 more seconds: it should be enough for the last expired messages to be removed, without affecting newer messages (which we expect to be there).
* | Merge pull request #2436 from rabbitmq/auth-attempt-metricsMichael Klishin2020-10-143-1/+12
|\ \ | | | | | | Add auth attemp metrics
| * | Reset detailed auth attempt metrics when gc'ing metricsauth-attempt-metricsdcorbacho2020-10-141-0/+4
| | |
| * | Add protocol to auth attempt metricsdcorbacho2020-10-142-7/+7
| | |