| Commit message (Collapse) | Author | Age | Files | Lines |
| |\
| |
| | |
Fix basic get message ready count
|
| | |
| |
| |
| |
| |
| |
| | |
Ensure the messages is ready is returned from basic get. Also fix
message count when using basic.delete.
[#162502929]
|
| |\ \
| | |
| | | |
Remove code that sets syslog listen IP
|
| |/ /
| |
| |
| | |
Fixes #1850
|
| |\ \
| | |
| | | |
Introduce a function that awaits startup with a timeout
|
| | | | |
|
| | | | |
|
| | | |
| | |
| | |
| | | |
Pair: @gerhard.
|
| | | |
| | |
| | |
| | |
| | |
| | | |
Per #1848 review.
Pair @gerhard.
|
| | | |
| | |
| | | |
BOOT_STATUS_SAMPLING_INTERVAL is in ms
|
| | | | |
|
| | | | |
|
| | | |
| | |
| | |
| | | |
Which supports a timeout.
|
| |\ \ \
| |_|/
|/| |
| | |
| | | |
rabbitmq/rabbitmq-server-1838-active-field-for-consumers
Update active flag for consumers
|
| | |\ \
| |/ /
|/| |
| | |
| | | |
Conflicts:
src/rabbit_fifo.erl
|
| |\ \ \
| |_|/
|/| | |
Queue length limit by byte size and number of messages (Drop head only)
|
| | | |
| | |
| | |
| | |
| | |
| | | |
Fixes bug introduced with queue limit changes.
[#161247380]
|
| | |\ \
| |/ /
|/| | |
|
| | | | |
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | | |
* Clarifications, less obscure or Erlang-centric language
* Link to relevant doc guides
* Prefer "mirror" or "follower" over "slave"
* Reduce the number or archaic versions mentioned
|
| | | |
| | |
| | |
| | | |
[ci skip]
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
This is the only place this function is used and this removes a
dependency cycle: rabbit_ct_broker_helpers can't depend on the broker:
the broker already depends on it as a test dependency.
[#159298729]
|
| | | | |
|
| | | |
| | |
| | |
| | |
| | | |
Now that force delete of queue is implemented the test assertion neede
updating.
|
| |\ \ \
| | | |
| | | | |
Always copy rabbit.schema file
|
| |/ / /
| | |
| | |
| | | |
Fixes #1843
|
| | | | |
|
| | | | |
|
| |/ /
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
Only drop-head strategy.
This necessitated the change of rabbit_fifo prefix messages from a tuple
of integers representing the number of returned vs enqueued messages
that have already been processes and thus don't need to include message
bodes in the snapshot to a tuple of lists of the sizes of each message.
This change will have some performance impact as the snaphots will now
be larger than before but as they still won't contain message bodies at
least the sizing is fixed. Decreased the frequency as snapshots points
are prepared so somewhat make up for this.
[#161247380]
|
| | |
| |
| |
| | |
References rabbitmq/rabbitmq-cli#292.
|
| | |
| |
| |
| |
| |
| |
| |
| | |
It joins the club of is_booted/1 and is_running/{0, 1}.
This allows for a CLI command that checks if the node is still
botting.
References rabbitmq/rabbitmq-cli#292.
|
| | |
| |
| |
| |
| |
| | |
[#163298456]
Fixes #1838
|
| | |
| |
| |
| |
| |
| | |
[#163298456]
Fixes #1838
|
| | |\
| |/
|/|
| |
| | |
Conflicts:
src/rabbit_fifo.erl
|
| | |
| |
| |
| |
| |
| | |
Light refactoring
Shortening some lines for the benefit of split buffer users.
|
| |/
|
|
|
|
|
|
|
|
| |
Flag is true by default. Can be set to false in QQ when the consumer
node is suspected to be down. When single active consumer is enabled, on
the queue, only one consumer is active at a time.
[#163298456]
References #1838
|
| | |
|
| |\
| |
| |
| |
| | |
rabbitmq/rabbitmq-management-649-single-active-consumer
Integrate single active consumer with monitoring
|
| | |\
| | |
| | |
| | |
| | | |
Conflicts:
src/rabbit_fifo.erl
|
| | | |
| | |
| | |
| | |
| | | |
For quorum queues. Otherwise dead waiting consumers can be kept in the state
between restarts.
|
| | | |
| | |
| | |
| | |
| | |
| | | |
[#163089472]
References rabbitmq/rabbitmq-management#649
|
| | | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
* Add single consumer tag and channel PID to metrics infos in quorum
queues
* Include waiting consumers in consumer count in quorum queues
* Add single active consumer flag in consumer metrics
* Update metrics for newly-promoted single active consumer
[#163089472]
References rabbitmq/rabbitmq-management#649
|
| | |\ \ |
|
| | | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | | |
WIP for quorum queue.
[#163089472]
References rabbitmq/rabbitmq-management#649
|
| |\ \ \ \
| |_|_|/
|/| | | |
Add an upgrade function to remove all default bindings.
|
| | | | |
| | | |
| | | |
| | | |
| | | | |
Non-durable queues and bindings are not on disk anyways.
This should be changes when moving to feature flags.
|
| | | | | |
|
| | | | | |
|
| | | | | |
|
| | | |/
| |/|
| | |
| | |
| | |
| | |
| | |
| | |
| | | |
Versions before 3.8 create default bindings for queues in the database.
Since #1721 they are replaced with placeholders only for list operations.
We need to cleanup the bindings to improve binding performance with
older queues.
[#163224049]
|