summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #1849 from rabbitmq/basic_get_message_ready_countMichael Klishin2019-01-294-51/+65
|\ | | | | Fix basic get message ready count
| * Fix basic get message ready countkjnilsson2019-01-284-51/+65
| | | | | | | | | | | | | | Ensure the messages is ready is returned from basic get. Also fix message count when using basic.delete. [#162502929]
* | Merge pull request #1851 from rabbitmq/rabbitmq-server-1850Michael Klishin2019-01-291-31/+1
|\ \ | | | | | | Remove code that sets syslog listen IP
| * | Remove code that sets syslog listen IPLuke Bakken2019-01-281-31/+1
|/ / | | | | | | Fixes #1850
* | Merge pull request #1848 from rabbitmq/await_startup_with_a_timeoutMichael Klishin2019-01-281-18/+78
|\ \ | | | | | | Introduce a function that awaits startup with a timeout
| * | SpacingMichael Klishin2019-01-281-1/+1
| | |
| * | Reintroduce the comment added in b0dd88351314cb4e0afca79cafa6bf315b42cbeeMichael Klishin2019-01-281-0/+1
| | |
| * | rabbit:await_startup: progress reportingMichael Klishin2019-01-281-26/+35
| | | | | | | | | | | | Pair: @gerhard.
| * | await_startup: use default timeouts in ms, namingMichael Klishin2019-01-281-9/+14
| | | | | | | | | | | | | | | | | | Per #1848 review. Pair @gerhard.
| * | Add commentLuke Bakken2019-01-281-0/+1
| | | | | | | | | BOOT_STATUS_SAMPLING_INTERVAL is in ms
| * | rabbit:await_startup/{0,1,2}: move spec definitions to definitionMichael Klishin2019-01-281-4/+7
| | |
| * | rabbit:await_startup/2: correct type specMichael Klishin2019-01-281-1/+1
| | |
| * | Introduce rabbit:await_startup/2Michael Klishin2019-01-251-14/+55
| | | | | | | | | | | | Which supports a timeout.
* | | Merge pull request #1839 from ↵Daniil Fedotov2019-01-288-93/+283
|\ \ \ | |_|/ |/| | | | | | | | rabbitmq/rabbitmq-server-1838-active-field-for-consumers Update active flag for consumers
| * | Merge branch 'master' into rabbitmq-server-1838-active-field-for-consumersArnaud Cogoluègnes2019-01-2520-549/+1054
| |\ \ | |/ / |/| | | | | | | | Conflicts: src/rabbit_fifo.erl
* | | Merge pull request #1834 from rabbitmq/qq-queue-length-drop-headMichael Klishin2019-01-258-364/+766
|\ \ \ | |_|/ |/| | Queue length limit by byte size and number of messages (Drop head only)
| * | Ensure purge clears out returned messageskjnilsson2019-01-251-7/+9
| | | | | | | | | | | | | | | | | | Fixes bug introduced with queue limit changes. [#161247380]
| * | Merge branch 'master' into qq-queue-length-drop-headMichael Klishin2019-01-2511-173/+273
| |\ \ | |/ / |/| |
* | | rabbitmq-plugins.8: document more flags, link to the relevant doc guideMichael Klishin2019-01-252-17/+82
| | |
* | | Man page edits and updatesMichael Klishin2019-01-256-141/+167
| | | | | | | | | | | | | | | | | | | | | * 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
* | | Man pages: update datesMichael Klishin2019-01-254-4/+4
| | | | | | | | | | | | [ci skip]
* | | backing_queue_SUITE:: Move `get_queue_sup_pid()` from rabbitmq-ct-helpersJean-Sébastien Pédron2019-01-241-1/+17
| | | | | | | | | | | | | | | | | | | | | | | | 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]
* | | dynamic_qq_SUITE: "force delete" was implemented, remove the TODOJean-Sébastien Pédron2019-01-241-1/+0
| | |
* | | Fix dynamic_qq test expectationkjnilsson2019-01-241-3/+2
| | | | | | | | | | | | | | | Now that force delete of queue is implemented the test assertion neede updating.
* | | Merge pull request #1845 from rabbitmq/rabbitmq-server-1843-always-copy-schemaMichael Klishin2019-01-243-9/+3
|\ \ \ | | | | | | | | Always copy rabbit.schema file
| * | | Always copy rabbit.schema fileLuke Bakken2019-01-233-9/+3
|/ / / | | | | | | | | | Fixes #1843
| * | remove a few stale TODOskjnilsson2019-01-251-5/+1
| | |
| * | tidy upkjnilsson2019-01-242-17/+0
| | |
| * | Quorum queue queue length limit by byte size and number of messagesDiana Corbacho2019-01-249-344/+764
|/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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]
* | Introduce rabbit:is_booted/0, is_booting/0Michael Klishin2019-01-201-1/+5
| | | | | | | | References rabbitmq/rabbitmq-cli#292.
* | Export rabbit:is_booting/1Michael Klishin2019-01-201-1/+1
| | | | | | | | | | | | | | | | 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.
| * Add consumer activity status to metricsArnaud Cogoluègnes2019-01-245-34/+38
| | | | | | | | | | | | [#163298456] Fixes #1838
| * Return active and activity status when listing consumersArnaud Cogoluègnes2019-01-215-37/+138
| | | | | | | | | | | | [#163298456] Fixes #1838
| * Merge branch 'master' into rabbitmq-server-1838-active-field-for-consumersArnaud Cogoluègnes2019-01-181-98/+137
| |\ | |/ |/| | | | | Conflicts: src/rabbit_fifo.erl
* | rabbit_fifo: refactoringkjnilsson2019-01-171-99/+138
| | | | | | | | | | | | Light refactoring Shortening some lines for the benefit of split buffer users.
| * Update active flag for consumersArnaud Cogoluègnes2019-01-183-44/+129
|/ | | | | | | | | | 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
* Fix test setupkjnilsson2019-01-171-1/+1
|
* Merge pull request #1826 from ↵Karl Nilsson2019-01-176-46/+239
|\ | | | | | | | | rabbitmq/rabbitmq-management-649-single-active-consumer Integrate single active consumer with monitoring
| * Merge branch 'master' into rabbitmq-management-649-single-active-consumerArnaud Cogoluègnes2019-01-167-84/+83
| |\ | | | | | | | | | | | | Conflicts: src/rabbit_fifo.erl
| * | Monitor waiting consumers when entering stateArnaud Cogoluègnes2019-01-161-4/+69
| | | | | | | | | | | | | | | For quorum queues. Otherwise dead waiting consumers can be kept in the state between restarts.
| * | Add single active field when listing consumersArnaud Cogoluègnes2019-01-164-12/+34
| | | | | | | | | | | | | | | | | | [#163089472] References rabbitmq/rabbitmq-management#649
| * | Integrate single active consumer with metricsArnaud Cogoluègnes2019-01-155-33/+122
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * 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
| * | Merge branch 'master' into rabbitmq-management-649-single-active-consumerArnaud Cogoluègnes2019-01-15218-330/+794
| |\ \
| * | | Add single active consumer monitoring info to classic queueArnaud Cogoluègnes2019-01-112-1/+17
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | WIP for quorum queue. [#163089472] References rabbitmq/rabbitmq-management#649
* | | | Merge pull request #1832 from rabbitmq/default-binding-cleanup-upgrade-functionMichael Klishin2019-01-162-1/+38
|\ \ \ \ | |_|_|/ |/| | | Add an upgrade function to remove all default bindings.
| * | | Only remove durable bindings for durable queues.Daniil Fedotov2019-01-162-7/+2
| | | | | | | | | | | | | | | | | | | | Non-durable queues and bindings are not on disk anyways. This should be changes when moving to feature flags.
| * | | Extract function, add loggingMichael Klishin2019-01-162-13/+33
| | | |
| * | | WordingMichael Klishin2019-01-161-3/+4
| | | |
| * | | Upgrade functions are expected to return a 'ok'Michael Klishin2019-01-161-1/+2
| | | |
| * | | Add an upgrade function to remove all default bindings.Daniil Fedotov2019-01-152-0/+20
| | |/ | |/| | | | | | | | | | | | | | | | | | | | | | 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]