Commit 0b82689
amqqueue_process: adopt new
As the de-duplication plugin is the only adopter of the `is_duplicate`
callback, we now use a simpler signature.
When a message is deemed duplicated, we discard it and re-route it to
dead letter exchange.
Signed-off-by: Matteo Cafasso <[email protected]>
(cherry picked from commit f93baa3)
(cherry picked from commit 8d7535e)
# Conflicts:
# .github/workflows/check-build-system-equivalence.yaml
# .github/workflows/gazelle-scheduled.yaml
# .github/workflows/oci-arm64-make.yaml
# .github/workflows/oci-make.yaml
# .github/workflows/templates/test.template.yaml
# .github/workflows/test-authnz.yaml
# .github/workflows/test-make-target.yaml
# .github/workflows/test-make.yaml
# .github/workflows/test-management-ui-for-pr.yaml
# .github/workflows/test-management-ui.yaml
# .github/workflows/test-mixed-versions.yaml
# .github/workflows/test-plugin-mixed.yaml
# .github/workflows/test-plugin.yaml
# .github/workflows/test.yaml
# COMMUNITY_SUPPORT.md
# MODULE.bazel
# Makefile
# bazel/BUILD.horus
# bazel/BUILD.redbug
# bazel/bzlmod/secondary_umbrella.bzl
# deps/amqp10_client/BUILD.bazel
# deps/amqp10_client/app.bzl
# deps/amqp10_client/src/amqp10_client.erl
# deps/amqp10_client/src/amqp10_client_connection.erl
# deps/amqp10_client/src/amqp10_client_frame_reader.erl
# deps/amqp10_client/src/amqp10_client_session.erl
# deps/amqp10_client/src/amqp10_client_types.erl
# deps/amqp10_client/src/amqp10_msg.erl
# deps/amqp10_client/test/system_SUITE.erl
# deps/amqp10_common/app.bzl
# deps/amqp_client/src/amqp_network_connection.erl
# deps/oauth2_client/app.bzl
# deps/oauth2_client/include/oauth2_client.hrl
# deps/oauth2_client/src/oauth2_client.erl
# deps/oauth2_client/test/system_SUITE.erl
# deps/oauth2_client/test/unit_SUITE.erl
# deps/rabbit/BUILD.bazel
# deps/rabbit/Makefile
# deps/rabbit/app.bzl
# deps/rabbit/ct.test.spec
# deps/rabbit/include/rabbit_amqp.hrl
# deps/rabbit/src/mc.erl
# deps/rabbit/src/mc_amqp.erl
# deps/rabbit/src/mc_amqpl.erl
# deps/rabbit/src/mc_compat.erl
# deps/rabbit/src/mc_util.erl
# deps/rabbit/src/rabbit_access_control.erl
# deps/rabbit/src/rabbit_amqp_management.erl
# deps/rabbit/src/rabbit_amqp_reader.erl
# deps/rabbit/src/rabbit_amqp_session.erl
# deps/rabbit/src/rabbit_amqp_util.erl
# deps/rabbit/src/rabbit_amqp_writer.erl
# deps/rabbit/src/rabbit_amqqueue.erl
# deps/rabbit/src/rabbit_amqqueue_process.erl
# deps/rabbit/src/rabbit_binding.erl
# deps/rabbit/src/rabbit_channel.erl
# deps/rabbit/src/rabbit_core_ff.erl
# deps/rabbit/src/rabbit_db_binding.erl
# deps/rabbit/src/rabbit_db_cluster.erl
# deps/rabbit/src/rabbit_db_exchange.erl
# deps/rabbit/src/rabbit_depr_ff_extra.erl
# deps/rabbit/src/rabbit_deprecated_features.erl
# deps/rabbit/src/rabbit_exchange.erl
# deps/rabbit/src/rabbit_feature_flags.erl
# deps/rabbit/src/rabbit_ff_controller.erl
# deps/rabbit/src/rabbit_ff_extra.erl
# deps/rabbit/src/rabbit_ff_registry.erl
# deps/rabbit/src/rabbit_ff_registry_factory.erl
# deps/rabbit/src/rabbit_ff_registry_wrapper.erl
# deps/rabbit/src/rabbit_global_counters.erl
# deps/rabbit/src/rabbit_khepri.erl
# deps/rabbit/src/rabbit_mnesia.erl
# deps/rabbit/src/rabbit_networking.erl
# deps/rabbit/src/rabbit_prelaunch_feature_flags.erl
# deps/rabbit/src/rabbit_queue_type.erl
# deps/rabbit/src/rabbit_quorum_queue.erl
# deps/rabbit/src/rabbit_reader.erl
# deps/rabbit/src/rabbit_stream_queue.erl
# deps/rabbit/test/amqp_address_SUITE.erl
# deps/rabbit/test/amqp_auth_SUITE.erl
# deps/rabbit/test/amqp_client_SUITE.erl
# deps/rabbit/test/amqp_system_SUITE.erl
# deps/rabbit/test/dead_lettering_SUITE.erl
# deps/rabbit/test/disconnect_detected_during_alarm_SUITE.erl
# deps/rabbit/test/feature_flags_v2_SUITE.erl
# deps/rabbit/test/mc_unit_SUITE.erl
# deps/rabbit/test/quorum_queue_SUITE.erl
# deps/rabbit/test/rabbit_db_binding_SUITE.erl
# deps/rabbit/test/rabbit_db_queue_SUITE.erl
# deps/rabbit/test/topic_permission_SUITE.erl
# deps/rabbit_common/mk/rabbitmq-early-plugin.mk
# deps/rabbit_common/src/rabbit_core_metrics.erl
# deps/rabbit_common/src/rabbit_env.erl
# deps/rabbit_common/src/rabbit_event.erl
# deps/rabbit_common/src/rabbit_ssl_options.erl
# deps/rabbit_common/test/rabbit_env_SUITE.erl
# deps/rabbitmq_amqp_client/src/rabbitmq_amqp_client.erl
# deps/rabbitmq_auth_backend_http/examples/rabbitmq_auth_backend_spring_boot/pom.xml
# deps/rabbitmq_auth_backend_http/examples/rabbitmq_auth_backend_spring_boot_kotlin/pom.xml
# deps/rabbitmq_auth_backend_http/src/rabbit_auth_backend_http.erl
# deps/rabbitmq_auth_backend_ldap/src/rabbit_auth_backend_ldap.erl
# deps/rabbitmq_auth_backend_oauth2/BUILD.bazel
# deps/rabbitmq_auth_backend_oauth2/Makefile
# deps/rabbitmq_auth_backend_oauth2/README.md
# deps/rabbitmq_auth_backend_oauth2/app.bzl
# deps/rabbitmq_auth_backend_oauth2/priv/schema/rabbitmq_auth_backend_oauth2.schema
# deps/rabbitmq_auth_backend_oauth2/src/rabbit_auth_backend_oauth2.erl
# deps/rabbitmq_auth_backend_oauth2/src/rabbit_oauth2_schema.erl
# deps/rabbitmq_auth_backend_oauth2/src/rabbit_oauth2_scope.erl
# deps/rabbitmq_auth_backend_oauth2/src/uaa_jwks.erl
# deps/rabbitmq_auth_backend_oauth2/src/uaa_jwt.erl
# deps/rabbitmq_auth_backend_oauth2/src/uaa_jwt_jwt.erl
# deps/rabbitmq_auth_backend_oauth2/test/config_schema_SUITE_data/rabbitmq_auth_backend_oauth2.snippets
# deps/rabbitmq_auth_backend_oauth2/test/jwks_SUITE.erl
# deps/rabbitmq_auth_backend_oauth2/test/rabbit_oauth2_schema_SUITE.erl
# deps/rabbitmq_auth_backend_oauth2/test/system_SUITE.erl
# deps/rabbitmq_auth_backend_oauth2/test/unit_SUITE.erl
# deps/rabbitmq_cli/Makefile
# deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/list_connections_command.ex
# deps/rabbitmq_event_exchange/BUILD.bazel
# deps/rabbitmq_event_exchange/Makefile
# deps/rabbitmq_event_exchange/README.md
# deps/rabbitmq_event_exchange/app.bzl
# deps/rabbitmq_event_exchange/priv/schema/rabbitmq_event_exchange.schema
# deps/rabbitmq_event_exchange/src/rabbit_exchange_type_event.erl
# deps/rabbitmq_event_exchange/test/config_schema_SUITE_data/rabbitmq_event_exchange.snippets
# deps/rabbitmq_event_exchange/test/system_SUITE.erl
# deps/rabbitmq_management/.gitignore
# deps/rabbitmq_management/BUILD.bazel
# deps/rabbitmq_management/Makefile
# deps/rabbitmq_management/app.bzl
# deps/rabbitmq_management/priv/schema/rabbitmq_management.schema
# deps/rabbitmq_management/priv/www/css/main.css
# deps/rabbitmq_management/priv/www/js/dispatcher.js
# deps/rabbitmq_management/priv/www/js/global.js
# deps/rabbitmq_management/priv/www/js/main.js
# deps/rabbitmq_management/priv/www/js/oidc-oauth/helper.js
# deps/rabbitmq_management/priv/www/js/tmpl/connection.ejs
# deps/rabbitmq_management/priv/www/js/tmpl/connections.ejs
# deps/rabbitmq_management/priv/www/js/tmpl/deprecated-features.ejs
# deps/rabbitmq_management/priv/www/js/tmpl/feature-flags.ejs
# deps/rabbitmq_management/src/rabbit_mgmt_dispatcher.erl
# deps/rabbitmq_management/src/rabbit_mgmt_wm_auth.erl
# deps/rabbitmq_management/test/clustering_prop_SUITE.erl
# deps/rabbitmq_management/test/config_schema_SUITE_data/rabbitmq_management.snippets
# deps/rabbitmq_management/test/rabbit_mgmt_http_SUITE.erl
# deps/rabbitmq_management/test/rabbit_mgmt_wm_auth_SUITE.erl
# deps/rabbitmq_management_agent/src/rabbit_mgmt_ff.erl
# deps/rabbitmq_mqtt/BUILD.bazel
# deps/rabbitmq_mqtt/Makefile
# deps/rabbitmq_mqtt/src/mc_mqtt.erl
# deps/rabbitmq_mqtt/src/rabbit_mqtt.erl
# deps/rabbitmq_mqtt/src/rabbit_mqtt_ff.erl
# deps/rabbitmq_mqtt/src/rabbit_mqtt_processor.erl
# deps/rabbitmq_mqtt/src/rabbit_mqtt_reader.erl
# deps/rabbitmq_mqtt/test/java_SUITE_data/pom.xml
# deps/rabbitmq_mqtt/test/mc_mqtt_SUITE.erl
# deps/rabbitmq_mqtt/test/mqtt_shared_SUITE.erl
# deps/rabbitmq_prometheus/BUILD.bazel
# deps/rabbitmq_prometheus/app.bzl
# deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_global_metrics_collector.erl
# deps/rabbitmq_prometheus/src/rabbit_prometheus_dispatcher.erl
# deps/rabbitmq_prometheus/test/rabbit_prometheus_http_SUITE.erl
# deps/rabbitmq_stream/test/protocol_interop_SUITE.erl
# deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/pom.xml
# deps/rabbitmq_stream_management/priv/www/js/tmpl/streamConnection.ejs
# deps/rabbitmq_stream_management/test/http_SUITE_data/pom.xml
# deps/rabbitmq_web_mqtt/src/rabbit_web_mqtt_handler.erl
# moduleindex.yaml
# rabbitmq-components.mk
# rabbitmq.bzl
# release-notes/4.0.1.md
# selenium/.gitignore
# selenium/bin/components/devkeycloak
# selenium/bin/components/fakeportal
# selenium/bin/components/fakeproxy
# selenium/bin/components/prodkeycloak
# selenium/bin/components/rabbitmq
# selenium/bin/components/uaa
# selenium/bin/gen-env-file
# selenium/bin/suite_template
# selenium/fakeportal/app.js
# selenium/full-suite-authnz-messaging
# selenium/full-suite-management-ui
# selenium/package.json
# selenium/run-suites.sh
# selenium/short-suite-management-ui
# selenium/suites/authnz-messaging/auth-internal-backend.sh
# selenium/suites/authnz-mgt/oauth-with-uaa.sh
# selenium/test/amqp.js
# selenium/test/authnz-msg-protocols/amqp10.js
# selenium/test/authnz-msg-protocols/env.auth-oauth-dev.docker
# selenium/test/authnz-msg-protocols/env.auth-oauth-dev.local
# selenium/test/authnz-msg-protocols/env.auth-oauth-prod.docker
# selenium/test/authnz-msg-protocols/env.auth-oauth-prod.local
# selenium/test/authnz-msg-protocols/env.docker.devkeycloak
# selenium/test/authnz-msg-protocols/env.docker.prodkeycloak
# selenium/test/authnz-msg-protocols/env.local.devkeycloak
# selenium/test/authnz-msg-protocols/env.local.prodkeycloak
# selenium/test/authnz-msg-protocols/mqtt.js
# selenium/test/basic-auth/env.local
# selenium/test/basic-auth/imports/users.json
# selenium/test/basic-auth/rabbitmq.conf
# selenium/test/connections/amqp10/sessions-for-monitoring-user.js
# selenium/test/env.docker
# selenium/test/env.local
# selenium/test/env.tls.docker
# selenium/test/env.tls.local
# selenium/test/exchanges/management.js
# selenium/test/multi-oauth/env.local
# selenium/test/multi-oauth/env.local.devkeycloak
# selenium/test/multi-oauth/env.local.prodkeycloak
# selenium/test/multi-oauth/rabbitmq.tls.conf
# selenium/test/oauth/env.docker.fakeportal
# selenium/test/oauth/env.docker.fakeproxy
# selenium/test/oauth/env.docker.uaa
# selenium/test/oauth/env.local
# selenium/test/oauth/env.local.fakeportal
# selenium/test/oauth/env.local.keycloak
# selenium/test/oauth/env.local.uaa
# selenium/test/oauth/rabbitmq.conf
# selenium/test/oauth/rabbitmq.keycloak-mgt-oauth-provider.conf
# selenium/test/oauth/rabbitmq.tls.conf
# selenium/test/oauth/uaa/uaa.yml
# selenium/test/pageobjects/BasePage.js
# selenium/test/pageobjects/OverviewPage.jsis_duplicate backing queue callback1 parent c867fe2 commit 0b82689
File tree
266 files changed
+16440
-1
lines changed- .github
- DISCUSSION_TEMPLATE
- workflows
- templates
- bazel
- bzlmod
- deps
- amqp10_client
- src
- test
- amqp10_common
- include
- amqp_client/src
- oauth2_client
- include
- src
- test
- rabbit_common
- mk
- src
- test
- rabbitmq_amqp_client/src
- rabbitmq_auth_backend_http
- examples
- rabbitmq_auth_backend_spring_boot_kotlin
- rabbitmq_auth_backend_spring_boot
- src
- rabbitmq_auth_backend_ldap/src
- rabbitmq_auth_backend_oauth2
- include
- priv/schema
- src
- test
- config_schema_SUITE_data
- rabbitmq_cli
- lib/rabbitmq/cli/ctl/commands
- rabbitmq_event_exchange
- priv/schema
- src
- test
- config_schema_SUITE_data
- rabbitmq_management_agent/src
- rabbitmq_management
- priv
- schema
- www
- css
- js
- oidc-oauth
- tmpl
- src
- test
- config_schema_SUITE_data
- js
- test/oidc-oauth
- rabbitmq_mqtt
- src
- test
- java_SUITE_data
- rabbitmq_prometheus
- src
- collectors
- test
- rabbitmq_stream_management
- priv/www/js/tmpl
- test/http_SUITE_data
- rabbitmq_stream/test
- rabbit_stream_SUITE_data
- rabbitmq_web_mqtt/src
- rabbit
- include
- src
- test
- release-notes
- selenium
- bin
- components
- fakeportal
- suites
- authnz-messaging
- authnz-mgt
- mgt
- test
- authnz-msg-protocols
- basic-auth
- imports
- connections/amqp10
- exchanges
- multi-oauth
- oauth
- keycloak
- uaa
- pageobjects
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
266 files changed
+16440
-1
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
| 140 | + | |
| 141 | + | |
| 142 | + | |
| 143 | + | |
| 144 | + | |
| 145 | + | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
| 152 | + | |
| 153 | + | |
| 154 | + | |
| 155 | + | |
| 156 | + | |
| 157 | + | |
| 158 | + | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
| 175 | + | |
| 176 | + | |
| 177 | + | |
| 178 | + | |
| 179 | + | |
| 180 | + | |
| 181 | + | |
| 182 | + | |
| 183 | + | |
| 184 | + | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
| 194 | + | |
| 195 | + | |
| 196 | + | |
| 197 | + | |
| 198 | + | |
| 199 | + | |
| 200 | + | |
| 201 | + | |
| 202 | + | |
| 203 | + | |
| 204 | + | |
| 205 | + | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
23 | 23 | | |
24 | 24 | | |
25 | 25 | | |
| 26 | + | |
26 | 27 | | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
27 | 31 | | |
28 | 32 | | |
29 | 33 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
| 15 | + | |
15 | 16 | | |
16 | 17 | | |
17 | 18 | | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
18 | 24 | | |
19 | 25 | | |
20 | 26 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
| 50 | + | |
50 | 51 | | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
51 | 55 | | |
52 | 56 | | |
53 | 57 | | |
| |||
0 commit comments