Merge pull request #3470 from rabbitmq/stream-coord-cleanup-tasks
Stream coordinator: monitor task processes
This commit is contained in:
commit
214944f764
|
|
@ -634,7 +634,7 @@ run_action(Action, StreamId, #{node := _Node,
|
|||
ActionFun(),
|
||||
unlink(Coordinator)
|
||||
end),
|
||||
Effects = [],
|
||||
Effects = [{monitor, process, aux, Pid}],
|
||||
Actions = Actions0#{Pid => {StreamId, Action, Args}},
|
||||
{no_reply, Aux#aux{actions = Actions}, Log, Effects}.
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue