| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
fixes: https://github.com/rabbitmq/rabbitmq-server/issues/2615
|
|
|
|
| |
References rabbitmq/rabbitmq-website#1109
|
| |
|
|\
| |
| | |
Pass RABBITMQ_NODENAME via Windows service environment
|
| |
| |
| |
| |
| |
| |
| |
| | |
Without this change using anything other than `rabbit` or the `rabbitmq-env-conf.bat` file will result in `erlang_dist_running_with_unexpected_nodename`
Follow-up to #2673
cc @dumbbell @michaelklishin
|
|/ |
|
|\
| |
| |
| |
| | |
luos/allow_configuring_rabbitmq_base_multiple_times2
Windows service: allow overriding base service location
|
| |
| |
| |
| |
| |
| | |
Currently RABBITMQ_BASE is always dynamically picked up from the
environment. This change would fix it at the time of configuration
of the service allowing multiple RabbitMQ services to be configured.
|
| |
| |
| |
| |
| |
| |
| |
| | |
Connections to the stream plugin does not have a type, so they can
trigger some function_clause errors. This was the case when trying to
close a connection from rabbit_connection_tracking module. The function
now falls back to a simple gen_server call to the connection process for
connections without a type.
|
| | |
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
As the connection may crash during the previous declaration and a caught
error would be returned in amqp_connection:open_channel/1 that wasn't
handled previously. Exactly how things fail in this test is most likely
very timing dependent and may vary.
Also fixes mqtt test where the process that set up a mock auth ETS table
was transient when an rpc timeout was introduced
|
| |
| |
| |
| | |
Fixes #2668
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| | |
This conforms with other http endpoints.
|
| |
| |
| |
| |
| |
| | |
[#175264017]
Signed-off-by: Mirah Gary <mgary@pivotal.io>
|
| |
| |
| |
| | |
:registry matches any registry, it's only a variable
|
| |
| |
| |
| |
| |
| |
| |
| |
| | |
Regardless of the value of `return_per_object_metrics`, this endpoint
always returns per-object metrics. This allows scraping both endpoints
at different intervals or scraping per-object metrics only during
debugging.
Co-authored-by: Mirah Gary <mgary@vmware.com>
|
| |
| |
| |
| | |
For start offset in stream queue.
|
| | |
|
| |
| |
| |
| |
| | |
Only the publisher ID is necessary now the publisher declaration is
mandatory before publishing.
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
| |
| |
| |
| |
| |
| |
| |
| | |
operations. At some point, these have to timeout to
avoid having lingering connection processes attempting
remote connections under unstable conditions.
Improve handling of potential call timeout exceptions
in amqp_gen_connection.
|
|/
|
|
|
|
|
|
|
|
|
| |
establishment. This guarantees that the effective
call timeouts are always safe, i.e. granting enough
time to the underlying network operations, which must
always timeout first in case of any unexpected
lingering operations leading to timeouts. This eliminates
the chance of leaking connection processes when call
timeouts elapse, while underlying remote cconnection
establishment call was still taking place.
|
|
|
|
| |
(cherry picked from commit 9963bb5b15166574d920f57bf1b05e575b436e5c)
|
|
|
|
| |
(cherry picked from commit 539b8d8b416b7295f0f7c7da137b59fc756b401e)
|
|
|
|
|
|
| |
Else an application that polled an empty quorum queue frequntly using basic.get
would never result in a snapshot being taken and results in unlimited
log growth.
|
|\
| |
| | |
Test stream queues with STOMP
|
| |
| |
| |
| |
| |
| | |
Stream queues require prefetch count and manual acknowledgment
(cherry picked from commit 45d3c3fecbf9f9782851bf580620a50bb4692a45)
|
|\ \
| | |
| | | |
Test stream queues with AMQP 1.0
|
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
Original PR https://github.com/rabbitmq/rabbitmq-amqp1.0/pull/104
cc @kjnilsson
cc @dcorbacho
|
| |/
|/|
| |
| |
| |
| | |
The queue decorator is called even when no links are present, which caused the
pg2 group to be created. At the same time, deleting a link wasn't deleting
the queue group. Closes #2497
|
| |
| |
| |
| | |
This is unused after the switch to the "monorepository".
|
|\ \
| | |
| | | |
Hide Purge option for stream queues
|
| | | |
|
| | |
| | |
| | |
| | |
| | | |
They were valid until the switch to the "monorepository" when everything
was merged into a single Git repository.
|
| | | |
|
| | |
| | |
| | |
| | | |
(cherry picked from commit 3e3ef927b2471ec90899f449919bbdfa74bc5311)
|
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
`rabbitmqctl enable_feature_flag all` enables all currently disabled feature flags.
While https://github.com/rabbitmq/rabbitmq-cli/issues/455 asked for
`--all`, I decided to just use "all" for consistency with
`rabbitmq-queues rebalance all`.
Closes rabbitmq/rabbitmq-cli#455
(cherry picked from commit af9e877848cfe4434de697d756e64014d180a945)
|
| |/
|/|
| |
| | |
In case the Mnesia record is stale.
|
|\ \
| | |
| | | |
Use correct credit mode x-credit
|