Module mqtt_sessions_process

code_change(Vsn, State, Extra) -> any()

fetch_queue(Pid::pid()) -> {ok, [map() | binary()]}

get_transport(Pid::pid()) -> {ok, pid()} | {error, notransport | noproc}

get_user_context(Pid::pid()) -> {ok, term()} | {error, noproc}

handle_call(Cmd, From, State) -> any()

handle_cast(X1, State) -> any()

handle_info(Info, State) -> any()

incoming_connect(Pid::pid(), Msg::mqtt_packet_map:mqtt_packet(), Options::mqtt_sessions:msg_options()) -> ok

incoming_data(Pid::pid(), Data::binary()) -> ok | {error, wrong_connection | mqtt_packet_map:decode_error()}

init(X1) -> any()

kill(Pid::pid()) -> ok

set_user_context(Pid::pid(), UserContext::term()) -> ok | {error, noproc}

start_link(Pool::atom(), ClientId::binary(), SessionOptions::mqtt_sessions:session_options()) -> {ok, pid()}

terminate(Reason, State) -> any()

update_user_context(Pid::pid(), Fun::fun((term()) -> term())) -> ok | {error, noproc}