Open
Description
enm goes into infinite loop with pipeline tcp connection - when tcp service is not running.
start() ->
enm:start_link(),
Url = "tcp://localhost:8789",
{ok,Push} = enm:push([{connect,Url},list]),
Send1 = "Hello, World!",
io:format("pushing message \"~s\"~n", [Send1]),
ok = enm:send(Push, Send1),
Send2 = "Goodbye.",
io:format("pushing message \"~s\"~n", [Send2]),
ok = enm:send(Push, Send2),
enm:close(Push),
enm:stop().
Scenario:
a. Connect Url is tcp
b. The tcp service is not running
c. Run the following code. I just did
$ erl -pa ebin deps/*/ebin
1> c("src/pipeline.erl").
{ok,pipeline}
3> pipeline:start().
pushing message "Hello, World!"
pushing message "Goodbye."
d. Look at top - the erlang process is taking 100% CPU.
e. CentOS - Linux version 3.10.0-123.20.1.el7.x86_64 ([email protected])
f. gcc version 4.8.2 20140120
Is it a known issue? Please let me know if its a user error.
Thanks.
Metadata
Metadata
Assignees
Labels
No labels