From 52b6bf1d5ea82c046da101aab418bebdc79ddda9 Mon Sep 17 00:00:00 2001 From: Jacob Vorreuter Date: Thu, 25 Aug 2011 16:53:34 -0700 Subject: [PATCH] tweak producer_callback param --- src/logplex_app.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/logplex_app.erl b/src/logplex_app.erl index 7480a845..0cc84a95 100644 --- a/src/logplex_app.erl +++ b/src/logplex_app.erl @@ -133,9 +133,9 @@ logplex_drain_buffer_args() -> StrNum2 -> list_to_integer(StrNum2) end, Dict = dict:from_list([ - {producer_callback, {ok, fun(_Pid, Action) -> + {producer_callback, fun(_Pid, Action) -> [Pid ! {logplex_drain_buffer, Action} ||{_,Pid,_,_} <- supervisor:which_children(logplex_worker_sup)] - end}} + end} ]), [{name, "logplex_drain_buffer"}, {max_length, MaxLength},