Behaviours: gen_server.
message() = #amqp_msg{}
opts() = #{id => term(), chunk_size => pos_integer(), exchange => binary()}
state() = #state{}
topic() = binary()
code_change/3 | |
handle_call/3 | |
handle_cast/2 | |
handle_info/2 | |
init/1 | |
publish/2 | |
start_link/2 | |
terminate/2 |
handle_info(Down::any(), State::state()) -> {noreply, state()} | {noreply, state(), millis()} | {stop, any(), state()}
init(X1::{host_opts(), opts()}) -> {ok, state()}
publish(Topic::topic(), Payload::binary()) -> ok
start_link(HostOpts::host_opts(), Opts::opts()) -> gen_server_startlink_ret()
terminate(Reason::any(), State::any()) -> ok
Generated by EDoc, Sep 22 2016, 10:39:34.