rabbitmq_sharding: support transactions on exchange callbacks

(cherry picked from commit 4caa14e)
rabbitmq · Sep 26, 2023 · 7b79139 · 7b79139
1 parent 9a4c009
commit 7b79139
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/deps/rabbitmq_sharding/src/rabbit_sharding_exchange_decorator.erl b/deps/rabbitmq_sharding/src/rabbit_sharding_exchange_decorator.erl
@@ -32,7 +32,7 @@ description() ->
 
 serialise_events(_X) -> false.
 
-create(none, X) ->
+create(_Tx, X) ->
     _ = maybe_start_sharding(X),
     ok.
 
@@ -48,7 +48,7 @@ active_for(X) ->
     end.
 
 %% we have to remove the policy from ?SHARDING_TABLE
-delete(none, X) ->
+delete(_Tx, X) ->
     _ = maybe_stop_sharding(X),
     ok.