Module vent_subscriber

Behaviours: gen_server.

Data Types

message()

message() = #amqp_msg{}

monitor_down()

monitor_down() = {'DOWN', reference(), process, pid(), any()}

opts()

opts() = #{id => term(), handler => module(), exchange => binary(), error_exchange => binary(), dead_letter_exchange => binary(), error_routing_key => binary(), n_workers => pos_integer(), prefetch_count => pos_integer(), queue => binary(), message_ttl => millis()}

state()

state() = #state{}

Function Index

code_change/3
handle_call/3
handle_cast/2
handle_info/2
init/1
start_link/2
terminate/2

Function Details

code_change/3

code_change(OldVsn::any(), State::state(), Extra::any()) -> {ok, state()}

handle_call/3

handle_call(Request::any(), From::any(), State::state()) -> {reply, ok, state()}

handle_cast/2

handle_cast(Msg::any(), State::state()) -> {noreply, state()}

handle_info/2

handle_info(Msg, State::state()) -> Result

init/1

init(X1::{host_opts(), opts()}) -> {ok, state()}

start_link/2

start_link(HostOpts::host_opts(), Opts::opts()) -> gen_server_startlink_ret()

terminate/2

terminate(Reason::any(), State::any()) -> ok


Generated by EDoc, Sep 22 2016, 10:39:34.