summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Add missing 'byte' type to amqp 0.9.1 record conversionstream-protocol-interoperabilitydcorbacho2020-10-281-1/+2
| | | | | The x-mqtt-publish-qos argument is a 'byte', without this MQTT can't publish to stream queues
* 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
| | |
| * | Add auth attemp metricsdcorbacho2020-10-142-1/+8
| | |
* | | Merge pull request #2470 from Ayanda-D/deprecated-kernel-poll-optionMichael Klishin2020-10-141-1/+0
|\ \ \ | | | | | | | | Remove deprecated kernel poll option (+K) from node start script
| * | | Kernel poll option (+K) was deprecated in OTP-21, on its release,Ayanda-D2020-10-141-1/+0
|/ / / | | | | | | | | | | | | | | | | | | | | | June-2018. Kernel-space poll has, since then, been set as the new default I/O polling mechanism at compile time. This removes the deprecated kernel poll option from `rabbimq-server` start script. Ref: http://blog.erlang.org/IO-Polling/
* | | Merge pull request #2468 from rabbitmq/avoid-double-channel-count-decreaseJean-Sébastien Pédron2020-10-144-32/+38
|\ \ \ | |/ / |/| | Attempt at improving the channel count consistency (+ improvements to testcases)
| * | quorum_queue_utils: wait_for_messages/2 now waits up to 30 secondsavoid-double-channel-count-decreaseJean-Sébastien Pédron2020-10-131-1/+1
| | | | | | | | | | | | | | | ... instead of 5 seconds. Hopefully, this should reduce the chance of failures in CI.
| * | rabbit_channel_tracking: Don't update channel tracking directly when a ↵Jean-Sébastien Pédron2020-10-131-2/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | connection is closed Tracking is already taken care of when each channel is closed. Removing this concurrent call to `unregister_tracked()` fixes a double-decrease of the counter. The reason is the counter is updated outside of a transaction and is therefore sensitive to concurrent read/modify/write sequences. A transaction would be a more appropriate solution, but it may be too resources-intensive in the scenario of high connection/channel churn.
| * | per_user_connection_channel_tracking_SUITE: Wait for conditionsJean-Sébastien Pédron2020-10-131-29/+30
| | | | | | | | | | | | | | | | | | | | | | | | | | | ... instead of checking it just after the channel/connection was closed. The problem with closing those resources is that the metric may be updated after the close function returns. There the check is time-sensitive. Waiting for the expected counter value fixes the problem.
| * | many_node_ha_SUITE: Limit timetrap to 5 minutesJean-Sébastien Pédron2020-10-131-0/+5
|/ /
* | Travis CI: Update config from rabbitmq-commonJean-Sébastien Pédron2020-10-131-3/+3
| |
* | Fix start offset for first offset consumingArnaud Cogoluègnes2020-10-091-0/+1
|/
* Merge pull request #2462 from rabbitmq/rabbitmq-management-844Michael Klishin2020-10-072-11/+72
|\ | | | | Several new functions for rabbit_alarms
| * Switch to new CT helpersrabbitmq-management-844Michael Klishin2020-10-061-4/+8
| |
| * Correct a Dialyzer specMichael Klishin2020-10-061-1/+1
| |
View Lorry Controller Status