Get ensure_dir right.
This commit is contained in:
parent
9443c17b26
commit
164d2923df
|
|
@ -52,8 +52,8 @@ init(Args) ->
|
||||||
amqp_channel:subscribe(Ch, #'basic.consume'{queue = Q,
|
amqp_channel:subscribe(Ch, #'basic.consume'{queue = Q,
|
||||||
no_ack = true}, self()),
|
no_ack = true}, self()),
|
||||||
{ok, Dir} = application:get_env(directory),
|
{ok, Dir} = application:get_env(directory),
|
||||||
ok = filelib:ensure_dir(Dir),
|
|
||||||
Filename = Dir ++ "/" ++ binary_to_list(pget(name, Args)) ++ ".log",
|
Filename = Dir ++ "/" ++ binary_to_list(pget(name, Args)) ++ ".log",
|
||||||
|
ok = filelib:ensure_dir(Filename),
|
||||||
{ok, F} = file:open(Filename, [append]),
|
{ok, F} = file:open(Filename, [append]),
|
||||||
rabbit_log:info("Tracer opened log file ~p~n", [Filename]),
|
rabbit_log:info("Tracer opened log file ~p~n", [Filename]),
|
||||||
{ok, #state{conn = Conn, ch = Ch, queue = Q, file = F}}.
|
{ok, #state{conn = Conn, ch = Ch, queue = Q, file = F}}.
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue