Packages

ensq

0.1.5
0.1.7 0.1.6 0.1.5

Erlang client for NSQ

Current section

Files

Jump to
Readme
3 Versions
3 Dependencies
Dependants
Files
Activity
ensq src ensq_channel_behaviour.erl
Raw

src/ensq_channel_behaviour.erl 

-module(ensq_channel_behaviour).



-callback init() ->

    {ok, State::term()}.



-callback response(Msg::binary(), State::term()) ->

    {ok, State::term()}.



-callback error(Msg::binary(), State::term()) ->

    {ok, State::term()} | {error, Reason::term()}.



-callback message(Msg::binary(), TouchFn::{term(), binary()}, State::term()) ->

    {ok, State::term()} | {requeue, State::term(), Timeout::non_neg_integer()}.