| Commit message (Collapse) | Author | Age | Files | Lines |
| | |
|
| |
|
|
| |
This reverts commit 838632f3dffd56c9112c0d546027e8ce45ec08fc.
|
| |
|
|
| |
This reverts commit eb079377b3064a646cf4f24f88fafcc2ba1a4a46.
|
| |
|
|
| |
This reverts commit 9aced82a5bdf25aa9819556e8ee1f5134668af18.
|
| |
|
|
|
|
| |
This reverts commit 229ac6bfb7429b12bfb9ebe37eb5431d90f7268c.
Fix syntax errors
|
| |
|
|
| |
This reverts commit 12e3ad79eef8c21b39502f3e3ff55f63ea479e21.
|
| |
|
|
| |
This reverts commit d8771acee402446071b945c76b9dc737e572b992.
|
| |
|
|
|
|
| |
This reverts commit 598c14f76ff593f19faa0a01458273dc5b09197b.
Add a broadcast
|
| |\
| |
| | |
Add some missing license headers
|
| |/ |
|
| | |
|
| | |
|
| |\
| |
| | |
Fix errors reported by Dialyzer
|
| | |
| |
| |
| |
| |
| |
| | |
The type spec of vhost limits is a list, possibly empty. A vhost is
initialized with an empty list.
Reported by Dialyzer.
|
| | |
| |
| |
| |
| |
| |
| | |
The result of this function is passed to `ssl:cipher_suites/2` which
expects the atom-based SSL/TLS versions.
Reported by Dialyzer.
|
| | |
| |
| |
| | |
Reported by Dialyzer.
|
| | |
| |
| |
| |
| |
| |
| |
| | |
Related to this: in `rabbit_mnesia`, remove dead code from the case
clause handling the return value of `rabbit_peer_discovery:lock/0`.
Indeed, the function never returns `Data` only.
Reported by Dialyzer.
|
| | |
| |
| |
| | |
Reported by Dialyzer.
|
| | |
| |
| |
| |
| |
| |
| | |
... instead of using a copy of the function from Erlang 20. This is
possible because the requirement was bumped to Erlang 21.
Reported by Dialyzer.
|
| | |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
register_connection/1
There is a race condition reported by Dialyzer because do a
read/write outside of a Mnesia transaction.
Historically there was a transaction, but it was removed in
commit e5df4e6ee105900087744ed40e58b8041738b9cd.
|
| | |
| |
| |
| |
| |
| |
| |
| |
| | |
... in put_user/3.
If the ets call behind `lookup_user/1` fails for another reason than the
entry was not found, it would be an exception anyway.
Reported by Dialyzer.
|
| |/
|
|
|
|
|
|
| |
list_local_mirrored_classic_without_synchronised_mirrors_for_cli/0
The return value was incorrectly spec'd.
Reported by Dialyzer.
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
|
| |
Otherwise they will show as failing if the latest build failed, even
when this build ran on a different branch.
Signed-off-by: Gerhard Lazu <gerhard@lazu.co.uk>
|
| |\
| |
| | |
Changed default configuration values related to quorum queues
|
| | |
| |
| |
| |
| |
| | |
Specifically:
- changed default quorum_commands_soft_limit from 256 to 32
- override Ra wal_max_batch_size to 4096
|
| |/
|
|
| |
Signed-off-by: Gerhard Lazu <gerhard@lazu.co.uk>
|
| |
|
|
| |
Signed-off-by: Gerhard Lazu <gerhard@lazu.co.uk>
|
| |\
| |
| | |
Improve handling of product name & version
|
| | |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
When the product name & version are not overridden, the common logged
message is the following one:
2020-04-24 15:08:51.754 [info] <0.263.0>
Starting RabbitMQ 3.8.0+rc.1.278.g5cdf562.dirty on Erlang 21.3.8.13
Copyright (c) 2007-2020 VMware, Inc. or its affiliates.
Licensed under the MPL 1.1. Website: https://rabbitmq.com
Now, when the product name or version are overridden, the "Starting"
line mentions them. There is a second line added with the base product
name & version:
2020-04-24 15:08:51.754 [info] <0.263.0>
Starting RabbitMQ Enterprise Edition 2020.04 on Erlang 21.3.8.13
Based on RabbitMQ 3.8.0+rc.1.278.g5cdf562.dirty
Copyright (c) 2007-2020 VMware, Inc. or its affiliates.
Licensed under the MPL 1.1. Website: https://rabbitmq.com
|
| |/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
Now, `rabbit:product_info/0` will report the base name & version
("RabbitMQ" and its actual version) separately from the final product
name & version (if any).
If the product name & version were not overridden in the configuration or
the environment, they will be missing from the product info return
value.
It allows caller to distinguish situations where the product name &
version were set or not.
An example use case is `rabbitmqctl status`: we want to report the
product name & version only if they were overridden. If they were not,
the "Product name" and "Product version" won't be added to the output.
Only "RabbitMQ version" will be displayed.
To help with the above, the map returned by `rabbit:product_info/0` also
contains a flag, `product_overridden`, set to true if they were.
Finally, the RabbitMQ version is often associated with the Erlang/OTP
release. So include this into the returned map. This will save an
additional RPC call if the remote caller is interested in both.
|
| |
|
|
|
|
|
| |
rabbitmq/revert-rabbitmq-server-2308-dead_queue_rejects"
This reverts commit 55d28f5ad3ad3a47791989bd118c6d8ce954eeca, reversing
changes made to 0bf8d0841c2467b93ab849f4f53a7bc99ab854e7.
|
| | |
|
| |\
| |
| | |
Handle "closed" return value
|
| | |
| |
| |
| |
| |
| |
| |
| | |
Turns out `port_please/2` and `port_please/3` can return `closed` - https://github.com/erlang/otp/pull/2616
We need to handle it here.
First reported via RabbitMQ public slack channel - https://rabbitmq.slack.com/archives/C1EDN83PA/p1588166195464400
|
| |/
|
|
| |
This suite has been flaky, but it only fails with a timeout trap on the whole test. By setting a timeout for invidual rabbitmqctl commands, it should be easier to discern in a flake where things got stalled.
|
| |
|
|
|
|
| |
So that more information is available in the logs upon test failure
https://3.basecamp.com/4467044/buckets/16481075/todos/2619089282
|
| |\
| |
| | |
Remove an outdated comment
|
| | | |
|
| | | |
|
| |\ \
| |/
|/| |
QQ: Fix crash bug when reaching delivery limit
|
| | |
| |
| |
| |
| |
| | |
This only happens when using basic.get but would crash the quorum queue
when the delivery limit was reached due to the transient basic.get
consumer being removed
|
| | | |
|
| |\ \
| | |
| | |
| | |
| | | |
rabbitmq/revert-rabbitmq-server-2308-dead_queue_rejects
Revert "Remove dead_queue_rejects test flake"
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
This reverts commit 9772aa8f8256a410bcc13ae5038f949ffe1d5b84.
Check RPC return value
Try a cast to fix test
|
| | | | |
|
| | | | |
|
| | | | |
|