summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* move parsing into core modulestream-refactoringkjnilsson2021-04-303-263/+487
* use new module for publisher confirm framekjnilsson2021-04-292-21/+33
* begin framing/command extraction workkjnilsson2021-04-291-0/+132
* Merge pull request #3007 from rabbitmq/mk-policy-event-formattingMichael Klishin2021-04-283-3/+24
|\
| * Convert policy event keys to atomsMichael Klishin2021-04-283-3/+24
|/
* Merge pull request #3006 from rabbitmq/mk-emit-policy-update-event-after-sche...Michael Klishin2021-04-282-14/+8
|\
| * Reduce log outputmk-emit-policy-update-event-after-schema-db-changesMichael Klishin2021-04-281-6/+0
| * Emit an internal event about policy change lastMichael Klishin2021-04-271-8/+8
* | Merge pull request #2992 from rabbitmq/stream-coord-safe-restartKarl Nilsson2021-04-271-68/+79
|\ \ | |/ |/|
| * Capture and log crashes on the stream coordinator machinestream-coord-safe-restartdcorbacho2021-04-211-68/+79
* | Use stream leader to query offsetArnaud Cogoluègnes2021-04-271-12/+10
* | streams: improve stream_status commandkjnilsson2021-04-271-10/+47
* | Merge pull request #3005 from rabbitmq/osiris-tracking-typesKarl Nilsson2021-04-272-4/+7
|\ \
| * | Make tracking status more genericosiris-tracking-typesArnaud Cogoluègnes2021-04-271-2/+2
| * | Report offset and offset type in tracking statusArnaud Cogoluègnes2021-04-271-1/+2
| * | Adapt stream code to osiris tracking types introductionArnaud Cogoluègnes2021-04-272-4/+6
* | | Merge pull request #2996 from rabbitmq/stream-add-replica-checkKarl Nilsson2021-04-273-20/+117
|\ \ \ | |/ / |/| |
| * | Streams: safer replica additionstream-add-replica-checkkjnilsson2021-04-273-20/+117
* | | Merge pull request #3002 from rabbitmq/stomp-for-streamsArnaud Cogoluègnes2021-04-265-2/+48
|\ \ \
| * | | Use = separator for stream offset STOMPstomp-for-streamsArnaud Cogoluègnes2021-04-262-8/+4
| * | | Support streams in STOMP pluginArnaud Cogoluègnes2021-04-265-2/+52
* | | | Merge pull request #2988 from rabbitmq/stream-plugin-blocks-ingress-on-disk-a...Karl Nilsson2021-04-261-12/+114
|\ \ \ \ | |/ / / |/| | |
| * | | Block stream publishing on disk alarmstream-plugin-blocks-ingress-on-disk-alarmArnaud Cogoluègnes2021-04-201-12/+114
* | | | Merge pull request #2993 from rabbitmq/rebalance-ignore-drainedMichael Klishin2021-04-231-1/+1
|\ \ \ \
| * | | | Revert "Increase ra:members/1 timeout to 60s"rebalance-ignore-drainedMichal Kuratczyk2021-04-221-2/+1
| * | | | Merge pull request #2973 from luos/mirror-sync-reduce-memory-useMichael Klishin2021-04-222-3/+15
| * | | | Set a default for consumer_timeoutkjnilsson2021-04-222-0/+9
| * | | | Change consistent to a dirty readMichal Kuratczyk2021-04-211-1/+1
| * | | | Increase ra:members/1 timeout to 60sdcorbacho2021-04-211-1/+2
| * | | | Ignore drained nodes when rebalancingMichal Kuratczyk2021-04-211-1/+1
| | |_|/ | |/| |
* | | | Merge pull request #2998 from rabbitmq/tag-branchMichael Klishin2021-04-232-4/+11
|\ \ \ \
| * | | | Tag docker image with branch nameDavid Ansari2021-04-232-4/+11
|/ / / /
* | | | Merge pull request #2973 from luos/mirror-sync-reduce-memory-useMichael Klishin2021-04-222-3/+15
* | | | Merge pull request #2990 from rabbitmq/consumer-timeout-defaultMichael Klishin2021-04-212-0/+9
|\ \ \ \ | |/ / / |/| | |
| * | | Set a default for consumer_timeoutconsumer-timeout-defaultkjnilsson2021-04-212-0/+9
| | |/ | |/|
* | | Merge pull request #2989 from Ayanda-D/channel-interceptor-amqp-errorsMichael Klishin2021-04-203-4/+69
|\ \ \ | |_|/ |/| |
| * | Allow #amqp_error{} responses in channel interceptorsAyanda-D2021-04-203-4/+69
|/ /
* | Merge pull request #2985 from rabbitmq/mk-decode-other-name-as-directory-stringMichael Klishin2021-04-201-4/+6
|\ \ | |/ |/|
| * Allow for more ASN.1 string (sub)typesMichael Klishin2021-04-201-2/+2
| * Decode other name using 'OTP-PUB-KEY':decode/2Michael Klishin2021-04-201-3/+5
| * SAN of type otherName: strip two leading charactersMichael Klishin2021-04-201-1/+1
|/
* Add rabbitmq_peer_discovery_k8s tests to bazelPhilip Kuryloski2021-04-191-0/+83
* Add rabbitmq_peer_discovery_etcd tests to bazelPhilip Kuryloski2021-04-192-0/+120
* Drop some Erlang 21-specific codeMichael Klishin2021-04-191-23/+0
* Pass DialyzerMichael Klishin2021-04-192-1/+7
* rabbit_common: pass DialyzerMichael Klishin2021-04-191-1/+1
* Merge branch 'fix-sh-concatenated-literal-parsing'Jean-Sébastien Pédron2021-04-192-6/+148
|\
| * rabbit_env: Fix Bourne shell concatenated literal parsingJean-Sébastien Pédron2021-04-192-6/+148
|/
* Add rabbitmq_peer_discovery_common tests to bazelPhilip Kuryloski2021-04-192-23/+95
* Remove a leftover commentMichael Klishin2021-04-191-3/+0