Module vent_publisher

Behaviours: gen_server.

Data Types

message()

message() = #amqp_msg{}

opts()

opts() = #{id => term(), chunk_size => pos_integer(), exchange => binary()}

state()

state() = #state{}

topic()

topic() = binary()

Function Index

code_change/3
handle_call/3
handle_cast/2
handle_info/2
init/1
publish/2
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::{publish, topic(), [message()]}, State::state()) -> {noreply, state()}

handle_info/2

handle_info(Down::any(), State::state()) -> {noreply, state()} | {noreply, state(), millis()} | {stop, any(), state()}

init/1

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

publish/2

publish(Topic::topic(), Payload::binary()) -> ok

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.