rabbitmq-server/deps/rabbitmq_mqtt/src
Péter Gömöri 2c1f1a1387
Restore credit_flow between channel/MQTT connection -> CQ processes
The credit_flow between publishing AMQP 0.9.1 channel (or MQTT
connection) and (non-mirrored) classic queue processes was
unintentionally removed in 4.0 together with anything else related to
CQ mirroring.

By default we restore the 3.x behaviour for non-mirored classic
queues. It is possible to disable flow-control (the earlier 4.0.x
behaviour) with the new env `classic_queue_flow_control`. In 3.x this
was possible with the config `mirroring_flow_control`.

(cherry picked from commit d65bd7d07a)
2024-12-09 22:33:47 -05:00
..
Elixir.RabbitMQ.CLI.Ctl.Commands.ListMqttConnectionsCommand.erl Remove unnecessary newline 2024-03-16 13:08:30 -04:00
mc_mqtt.erl 4.1: Avoid an exception when an AMQP 0-9-1-originating message with expiration set is converted for an MQTT consumer (#12710) 2024-11-13 09:20:43 +01:00
rabbit_mqtt.erl Emit histogram metric for received message sizes per protocol (#12342) 2024-09-24 18:08:24 +02:00
rabbit_mqtt_confirms.erl Support AMQP 1.0 natively 2024-02-28 14:15:20 +01:00
rabbit_mqtt_ff.erl rabbit_feature_flags: Introduce hard vs. soft required feature flags 2024-10-30 11:12:18 +01:00
rabbit_mqtt_internal_event_handler.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_keepalive.erl Revert "Format MQTT code with `erlfmt`" 2023-01-27 18:25:57 +00:00
rabbit_mqtt_packet.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_processor.erl Restore credit_flow between channel/MQTT connection -> CQ processes 2024-12-09 22:33:47 -05:00
rabbit_mqtt_qos0_queue.erl rabbit_queue_type: Add `{error,timeout}` to delete/4 callback spec 2024-09-16 14:43:24 -04:00
rabbit_mqtt_reader.erl Expose AMQP connection metrics 2024-11-02 19:08:24 +01:00
rabbit_mqtt_retained_msg_store.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_retained_msg_store_dets.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_retained_msg_store_ets.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_retained_msg_store_noop.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_retainer.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_retainer_sup.erl (c) year bumps 2024-01-01 22:02:20 -05:00
rabbit_mqtt_sup.erl Speed up AMQP connection and session (de)registration 2024-08-02 13:46:30 +02:00
rabbit_mqtt_util.erl Remove mqtt.default_user and mqtt.default_pass 2024-08-15 10:58:48 +00:00