| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
| |
This will ease the backport to 3.7.x where that feature flag does not
exist.
|
| | |
|
| | |
|
| |
|
|
| |
[#164931055]
|
| |\
| |
| | |
QQ SAC: process all consumers on noconnection
|
| |/
|
|
|
|
|
|
| |
There can be multiple single active consumers in the consumers map if
all but one are cancelled. Take this into account when processing
noconnections.
[#165438843]
|
| |\
| |
| | |
Reset overflow queue property to drop-head if policy is unset.
|
| | |
| |
| |
| |
| |
| |
| | |
If `overflow` policy is unset the actual queue property should reset
to it's default value.
Fixes #1980
|
| | | |
|
| |\ \
| | |
| | | |
Move rabbit_queue_collector to rabbit_common repo
|
| | |\ \
| |/ /
|/| | |
|
| | | | |
|
| | | | |
|
| |\ \ \
| |_|/
|/| | |
Track messages that were not routed anywhere and also not published as mandatory
|
| | | | |
|
| | | | |
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | | |
Some code paths only go through it, e.g. when
a transaction commits.
Pair: @dcorbacho.
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
so they have to be dropped.
Part of #1904.
[#165548314]
|
| |\ \ \
| | | |
| | | | |
print cuttlefish validation error on a new line
|
| |/ / / |
|
| |\ \ \
| | | |
| | | | |
Add functions to get erlang or openssl formatted ciphers.
|
| | | | |
| | | |
| | | |
| | | | |
Minimal supported erlang version is 21.3
|
| | | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | | |
SSL application provides API to get ciphers by format or by default/all/anonymous,
but not both, so it's not possible to get all openssl-formatted ciphers.
OTP-20 and OTP-21 have different modules containing cipher formatting
functions - using function_exported to support both.
Addresses rabbitmq/rabbitmq-cli#342
|
| |\ \ \ \ |
|
| | | | | |
| | | | |
| | | | |
| | | | |
| | | | | |
Incorrect argument formatting was exposed by the change
in #1990 and resulted in unit test failures.
|
| | | | | |
| | | | |
| | | | |
| | | | | |
ones
|
| | |\ \ \ \
|/ / / / /
| | | | |
| | | | | |
https://github.com/velimir/rabbitmq-server into velimir-schema-check-boot-failed
|
| | |/ / /
| | | |
| | | |
| | | | |
fixes #1985
|
| |\ \ \ \
| | | | |
| | | | | |
Report memory used by the ETS tables of the ra log
|
| | |\ \ \ \
| |/ / / /
|/| | | | |
|
| |\ \ \ \ \
| |_|/ / /
|/| | | | |
Consumer timeouts
|
| | | | | | |
|
| | | | | |
| | | | |
| | | | |
| | | | | |
To own function
|
| | | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | | |
If there are no pending acks we should allow the channel to enter
hibernate without being woken up by the tick timer.
[#164212469]
|
| | | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | | |
Also handle case where client does not support consumer cancellation and
rename the queue_cleanup timer to a generic "tick" timer for channels to
perform periodic activities.
[#164212469]
|
| | | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | |
| | | | | |
To put static fields into a nested record to avoid some copying on
update.
Also exit the channel when a basic.get times out.
[#164212469]
|
| | | |/ /
| |/| |
| | | |
| | | |
| | | |
| | | |
| | | | |
Such that if a consumer has a message awaiting ack for longer than this
timeout the consumer will either be cancelled (if the client supports
it) or the channel will be closed to ensure the message does not get
stuck permanently.
|
| | | | |
| | | |
| | | |
| | | | |
[#161752680]
|
| | |_|/
|/| |
| | |
| | |
| | |
| | |
| | | |
Collector is used by a connection supervisor, which may be on
the client side for direct connections.
Addresses rabbitmq-erlang-client#91
|
| |\ \ \
| | | |
| | | | |
Clarify unit symbols
|
| | |/ /
| | |
| | |
| | |
| | | |
RabbitMQ supports both power of 2 & power of 10 unit symbols. Giving
clear examples of the difference - it's a mistake easy to make.
|
| | | |
| | |
| | |
| | | |
This reverts commit 738604543a31f6ba5c5b92f475a85295c636df33.
|
| |/ /
| |
| |
| |
| | |
RabbitMQ supports both power of 2 & power of 10 unit symbols. Giving
clear examples of the difference - it's a mistake easy to make.
|
| | | |
|
| | |
| |
| |
| | |
The code already queries `rabbit_pbe`.
|
| |/
|
|
|
|
| |
alarms via rpc
Per discussion with @dumbbell.
|
| |
|
|
|
| |
... so that `status_with_alarm` works in a mixed-versions cluster
situation.
|
| |
|
|
|
|
|
|
|
| |
`cluster_status` output
The struct inside the `alarms` key was changed.
While here, change how the rabbitmqctl(8) output is parsed: we now parse
the Erlang structure instead of using regex.
|
| |
|
|
|
|
|
|
|
|
|
|
| |
The `app_management` testcase checks that status() works even with
RabbitMQ stopped (but the node is running). To restore that fact,
`totals` are only computed if RabbitMQ is running. Otherwise the list of
`totals` is empty.
The problem reported by the testcase without this patch was that the
`rabbit_vhost` Mnesia table was unavailable:
{exit,{aborted,{no_exists,rabbit_vhost}}}
|
| |\
| |
| | |
Status data structures update for 3.8
|