summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Test stream queues with STOMPrabbitmq-stomp-gh-153-monorepodcorbacho2020-11-172-1/+66
| | | | | | Stream queues require prefetch count and manual acknowledgment (cherry picked from commit 45d3c3fecbf9f9782851bf580620a50bb4692a45)
* rabbit_common: Remove the rabbitmq-github-actions Erlang.mk pluginJean-Sébastien Pédron2020-11-175-184/+3
| | | | This is unused after the switch to the "monorepository".
* Add rabbitmq_stream to the github-actions releated make goalsPhilip Kuryloski2020-11-171-0/+1
|
* Switch the Maintenance GitHub Actions workflow to a schedulePhilip Kuryloski2020-11-171-1/+3
| | | | | Run it at 2am every day, instead of on every push, so save github workers for our other workflows
* Merge pull request #2627 from rabbitmq/stream-purgeMichael Klishin2020-11-171-0/+2
|\ | | | | Hide Purge option for stream queues
| * Hide Purge option for stream queuesstream-purgedcorbacho2020-11-171-0/+2
| |
* | Remove unused .github directoriesJean-Sébastien Pédron2020-11-1769-23848/+0
| | | | | | | | | | They were valid until the switch to the "monorepository" when everything was merged into a single Git repository.
* | Move issue and PR templates to monorepo rootMichael Klishin2020-11-172-0/+0
| |
* | Drive by change: ignore ebin/*Michael Klishin2020-11-171-0/+1
| | | | | | | | (cherry picked from commit c80818fe9099cdf6047b6c40102b19871954a63a)
* | Wording and additional usage docsMichael Klishin2020-11-171-2/+8
| | | | | | | | (cherry picked from commit 3e3ef927b2471ec90899f449919bbdfa74bc5311)
* | Allow "all" as a feature flag nameMichal Kuratczyk2020-11-172-1/+19
| | | | | | | | | | | | | | | | | | | | | | `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)
* | Check if member processes are alive in metadata commandArnaud Cogoluègnes2020-11-172-73/+93
| | | | | | | | In case the Mnesia record is stale.
* | Merge pull request #2504 from rabbitmq/qq-credit-modePhilip Kuryloski2020-11-163-47/+45
|\ \ | | | | | | Use correct credit mode x-credit
| * | Remove unused functionqq-credit-modePhilip Kuryloski2020-11-161-10/+0
| | |
| * | Use correct credit mode x-creditkjnilsson2020-11-163-37/+45
| | | | | | | | | | | | | | | When the x-credit consumer arg is defined Quorum Queues should use use credit mode `credited` and not `simple_prefetch`.
* | | Add rabbitmq_stream to .gitignorePhilip Kuryloski2020-11-161-0/+1
| | |
* | | Merge remote-tracking branch 'rabbitmq_stream/master'Philip Kuryloski2020-11-1637-0/+13908
|\ \ \ | | | | | | | | | | | | Corresponding to master at a77b05d0d511899a39291d5f88219ec3738e9880
| * | | Move some code to utils moduleArnaud Cogoluègnes2020-11-052-97/+119
| | | |
| * | | Call rabbit_log:warning/2Arnaud Cogoluègnes2020-11-031-1/+1
| | | |
| * | | Update rabbitmq-components.mkArnaud Cogoluègnes2020-11-031-20/+42
| | | |
| * | | Return Erlang node long name in metadataArnaud Cogoluègnes2020-11-031-2/+11
| | | | | | | | | | | | | | | | Fixes #2
| * | | Merge pull request #1 from rabbitmq/management-integrationArnaud Cogoluègnes2020-10-233-55/+224
| |\ \ \ | | | | | | | | | | Emit stats for management
| | * | | Use non_amqp_connection name for force_refresh_eventArnaud Cogoluègnes2020-10-231-8/+8
| | | | |
| | * | | Support shutdown call from management pluginArnaud Cogoluègnes2020-10-231-0/+9
| | | | |
| | * | | Register connections and handle force_event_refreshArnaud Cogoluègnes2020-10-231-6/+16
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | For existing connections that must emit stats when the management plugin is enabled. References rabbitmq/rabbitmq-server#2481
| | * | | Merge branch 'master' into management-integrationArnaud Cogoluègnes2020-10-222-0/+175
| | |\ \ \ | | |/ / / | |/| | | | | | | | | | | | | Conflicts: src/rabbit_stream_manager.erl
| * | | | Support max-age in stream creationArnaud Cogoluègnes2020-10-221-0/+5
| | | | |
| * | | | Support leader locator strategiesArnaud Cogoluègnes2020-10-212-0/+184
| | | | | | | | | | | | | | | | | | | | References rabbitmq/rabbitmq-server#2471
| | * | | Check stats timer in listen loopArnaud Cogoluègnes2020-10-221-1/+2
| | | | |
| | * | | Add event notification during authenticationArnaud Cogoluègnes2020-10-201-28/+77
| | | | |
| | * | | Emit stats for managementArnaud Cogoluègnes2020-10-203-27/+141
| |/ / / | | | | | | | | | | | | WIP
| * | | Support initial-cluster-size argument on creationArnaud Cogoluègnes2020-10-163-19/+106
| | | | | | | | | | | | | | | | See rabbitmq/rabbitmq-server#2467
| * | | Check stream name before creationArnaud Cogoluègnes2020-10-163-15/+59
| | | | | | | | | | | | | | | | | | | | Should not start with "amq.", be empty. Strips also newline and carriage return characters.
| * | | Add CLI command to list stream connectionsArnaud Cogoluègnes2020-10-166-9/+346
| | | |
| * | | Add rabbitmq_ct_client_helpers dependencyArnaud Cogoluègnes2020-10-121-1/+1
| | | |
| * | | Add ct_client_helpers dependencyArnaud Cogoluègnes2020-10-121-1/+1
| | | |
| * | | Add INI-type configuration supportArnaud Cogoluègnes2020-10-123-0/+284
| | | |
| * | | Set default heartbeat to 60 secondsArnaud Cogoluègnes2020-10-122-4/+3
| | | |
| * | | Add correlation ID field in commit offset frameArnaud Cogoluègnes2020-10-022-1/+3
| | | | | | | | | | | | | | | | | | | | Not used yet, but can avoid a command version change if the command should have confirm response.
| * | | Bump dependencies in Java test suiteArnaud Cogoluègnes2020-09-295-655/+785
| | | | | | | | | | | | | | | | And apply Google Java Format with Maven Spotless plugin.
| * | | Adapt failure testsArnaud Cogoluègnes2020-09-295-15/+33
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | They are a bit more defensive. The subscription is also now more reliable by returning a stream-not-available code if necessary. Using also Aten poll interval to 1 second (bumped to 5 seconds in master now).
| * | | Use rabbit_durable_queue to check if stream existsArnaud Cogoluègnes2020-09-172-0/+10
| | | | | | | | | | | | | | | | | | | | | | | | | | | | This is done after checking rabbit_queue and if it returns that the queue does not exist. The coordinator may be recovering the queue, so thanks to this double check we know the queue exists but is not available, instead of thinking it does not exist at all.
| * | | Add offset tracking commandsArnaud Cogoluègnes2020-09-153-0/+87
| | | |
| * | | Adapt test to additional chunk type field in chunkArnaud Cogoluègnes2020-09-031-1/+2
| | | |
| * | | Add publisher IDArnaud Cogoluègnes2020-09-025-29/+49
| | | |
| * | | Use byte for sub ID in credit notificationArnaud Cogoluègnes2020-09-011-1/+1
| | | |
| * | | Change sub ID to byte in protocol referenceArnaud Cogoluègnes2020-09-011-5/+5
| | | |
| * | | Use byte for subscription IDArnaud Cogoluègnes2020-09-014-12/+12
| | | | | | | | | | | | | | | | | | | | Instead of integer. This is to be consistent with the introduction of a similar ID for publishers (which will be a byte as well).
| * | | Add debug log during deletionArnaud Cogoluègnes2020-08-071-0/+6
| | | |
| * | | Refactor Java tests after Client package changeArnaud Cogoluègnes2020-08-063-10/+14
| | | |
View Lorry Controller Status