diff options
Diffstat (limited to 'deps/rabbit/src/rabbit_khepri.erl')
| -rw-r--r-- | deps/rabbit/src/rabbit_khepri.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_khepri.erl b/deps/rabbit/src/rabbit_khepri.erl index fb1a4ea8cd..1c11dd1edd 100644 --- a/deps/rabbit/src/rabbit_khepri.erl +++ b/deps/rabbit/src/rabbit_khepri.erl @@ -654,10 +654,10 @@ register_simple_projection(Name, PathPattern, KeyPos) -> register_rabbit_bindings_projection() -> MapFun = fun(_Path, Binding) -> - Binding + #route{binding = Binding} end, ProjectionFun = projection_fun_for_sets(MapFun), - Options = #{type => bag, keypos => #binding.source}, + Options = #{keypos => #route.binding}, Projection = khepri_projection:new( rabbit_khepri_bindings, ProjectionFun, Options), PathPattern = [rabbit_db_binding, |