| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
(cherry picked from commit 31aa5874e8f2f6934b9a0d6b78e14a016e901b3c)
|
|\
| |
| | |
Fix memory leak when using mandatory flag in CQs (backport #3560)
|
| |\
| |/
|/| |
|
| | |
|
|\ \
| | |
| | | |
Fix memory_breakdown for connection procs (backport #3570)
|
|/ /
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
Instead of trying to read the ranch_server ETS table directly,
use an internal Ranch function that does the same. While neither
are documented, the latter is less likely to change.
(cherry picked from commit 0ee8a0612ebe7dcb5ef1cd5bf717c1cecac09bc7)
# Conflicts:
# release-notes/3.9.8.md
|
|/
|
|
|
|
|
| |
MsgNo is defined for both mandatory flags and confirms,
but only confirms need to be kept track of in this module.
(cherry picked from commit 7ffb154787446522e3838ef2230226b337665e4d)
|
|\
| |
| | |
Stream queue: handle unsupported header value types (backport #3565)
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
As AMQP 0.9.1 headers are translated into AMQP 1.0 application properties
they are not able to contain complex values such as arrays or tables.
RabbitMQ federation does use array and table values so to avoid crashing when
delivering a federated message to a stream queue we drop them. These header values
should be considered internal however so dropping them before a final queue deliver should not be a huge problem.
(cherry picked from commit 5520c6cafe715e324a810e715d00c8b61ed42190)
|
|\ \
| |/
|/| |
Allow having multiple `make run-broker` simulatneously (backport #3566)
|
|/
|
|
|
|
|
|
|
| |
It was automatically happening for e.g. `make start-cluster`.
But some plugins were not covered by default generated config, and
running rabbit from 2 different worktrees was a bit complicated.
(cherry picked from commit 23be565a38e7fc937f4a00c1a749a5f3fb236e96)
|
| |
|
| |
|
|\
| |
| | |
feat(prom): expose cluster id in identity (backport #3554)
|
|/
|
|
| |
(cherry picked from commit 84de860b4cb4ede01d0d57d2aacb158ad078aa7d)
|
|\
| |
| | |
Stream queue: use local pid for offset listeners (backport #3550)
|
|/
|
|
|
|
|
|
|
|
| |
When a consumer reaches the end of a stream it need to register an
offset listener with the local stream member so that it can be notified
when new stream messages are committed. The stream queue implementation
for some reason registered offset listeners with the leader, not the local
member.
(cherry picked from commit db3944cfc4eb80f0ee261f41b4fdaf331399f186)
|
|\
| |
| | |
Update osiris to 1.2.2
|
|/ |
|
|
|
|
| |
(cherry picked from commit 49a47586b075c19e5af521a3f1d333ed8fab4654)
|
|
|
|
| |
(cherry picked from commit 6a9790189cd26e03221a67e3396407794bd4259a)
|
|\
| |
| | |
fix: list exchanges in current virtual host in topic permissions (backport #3545)
|
|/
|
|
| |
(cherry picked from commit 5f81fff959302d445bc341eb834a8afb529f29b7)
|
|\
| |
| | |
Adopt otp 24.1.1 for OCI workflow (backport #3529)
|
| |
| |
| |
| | |
(cherry picked from commit 59fb2afce91060faa63b970b04ab427e776dbc2d)
|
|\ \
| |/
|/| |
Fix typo in UI help hint (backport #3533)
|
|/
|
|
| |
(cherry picked from commit 0f2a6123df398843ee79b08be25c039ef062ae42)
|
|\
| |
| | |
Fix handling of priv dirs for external deps (backport #3525)
|
|/
|
|
|
|
| |
These were placed incorrectly for rabbitmq_home rules in bazel
(cherry picked from commit 1d4ddceb5d4b24a161acf534e091d436ce6bbb91)
|
|\
| |
| | |
Move CT helpers to monorepo (backport #3516)
|
| | |
|
| | |
|
| | |
|
|\ \
| |/
|/| |
Emit identity info in prometheus /metrics/detailed endpoint (backport #3520)
|
|/
|
|
|
|
| |
This is needed to make filtering metrics on a cluster name possible.
(cherry picked from commit 989a2997209045b0093e967ded1aa973303ca907)
|
|
|
|
|
|
|
|
|
| |
The suite level timeout the .erl I've learned is actually per
case. By sharding bu testcase, we can better match the common test
level and bazel level timeouts, such that we can get logs from remote
test run failures.
(cherry picked from commit 9c9fb7ffb01c8bdfbf9bd98b5eeb7799a26b0901)
|
|\
| |
| | |
Reuse list of nodes in peer discovery plugins that use Erlang global locks (backport #3517)
|
|/
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
AWS, Kubernetes and Classic peer discovery plugins use list_nodes and
Erlang global:set_lock to create a mutex lock. To unlock, these plugins
get the latest list with list_nodes and call global:del_lock.
However, if list_nodes within unlock fails, RabbitMQ will throw an
uncaught exception and the lock will not be released until the node
holding the lock is restarted. This prevents new nodes from joining the
cluster.
This failure can be avoided by passing the list of nodes from lock to
unlock. If a node goes away (and comes back) between the lock and unlock
calls, del_lock could still successfully remove the lock. Similarly, if
a new node starts up between the lock and unlock calls, del_lock
wouldn't need to inform the new node.
(cherry picked from commit 7090199330fc0603b480ac1f4395831d240c6a9b)
|
|
|
|
| |
(cherry picked from commit e8d0d380a2a8b46c3884c20690aaefea54a8af68)
|
|
|
|
|
|
|
|
| |
The advertised_host must also be tried for TLS connections.
References #3514
(cherry picked from commit fc801382045d1eef708b9c9ec9373d1a87047056)
|
|\
| |
| | |
Update Osiris to 1.2.1
|
|/ |
|
|\
| |
| | |
Preserve stacktraces in propagated internal auth backend exceptions (backport #3511)
|
| |
| |
| |
| |
| |
| | |
exceptions.
(cherry picked from commit 3bce36b6674b1371bcc3596c9fa680d705b7ded4)
|
|\ \
| | |
| | | |
Support for advertising different hostname for TLS stream connections
|
| |/
| |
| |
| |
| |
| |
| | |
Use case: Allow plain connections over one (internal IP), and TLS
connections over another IP (eg. internet routable IP). Without this
patch a cluster can only support access over one or the other IP, not
both.
|
|\ \
| |/
|/| |
Handle no-context delivery in web stomp (backport #3509)
|
|/
|
|
|
|
|
|
|
|
|
| |
To support messages from streams, which do not have a
context (for credit flow).
References rabbitmq/rabbitmq-stomp#138
Fixes #3508
(cherry picked from commit b758edc64247ef8b33bf8c897b37013d9eef99ec)
|
|
|
|
|
|
| |
Remove redundant code in internal auth backend and queue consumers modules
(cherry picked from commit c78b04307bf87eb604ebe6b19abefaa9d22984dc)
|
|
|
|
| |
(cherry picked from commit e622c701fbfea086061b279478bd41e6eecd7ef2)
|