ezmq_test.erl

-module(ezmq_test).
-export([hwm/0]).

hwm() ->
    {ok, C} = ezmq:context(),
    {ok, S1} = ezmq:socket(C, pull),
    {ok, S2} = ezmq:socket(C, push),

    ok = ezmq:setsockopt(S2, linger, 0),
    ok = ezmq:setsockopt(S2, hwm, 5),

    ok = ezmq:bind(S1, "tcp://127.0.0.1:5858"),
    ok = ezmq:connect(S2, "tcp://127.0.0.1:5858"),

    ok = hwm_loop(10, S2),

    {ok, <<"test">>} = ezmq:recv(S1),
    ok = ezmq:send(S2, <<"test">>).

hwm_loop(0, _S) ->
    ok;
hwm_loop(N, S) when N > 5 ->
    ok = ezmq:send(S, <<"test">>, [noblock]),
    hwm_loop(N-1, S);
hwm_loop(N, S) ->
    {error, _Error} = ezmq:send(S, <<"test">>, [noblock]),
    hwm_loop(N-1, S).