Module mqtt_sessions_retain

cleanup(Pool::atom()) -> ok

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

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

handle_cast(Cmd, State) -> any()

handle_info(Info, State) -> any()

init(X1::[atom()]) -> {ok, #state{pool = atom(), topics = ets:tab(), messages = ets:tab()}}

lookup(Pool::atom(), TopicFilter::[binary()]) -> {ok, [{mqtt_packet_map:mqtt_message(), term()}]}

retain(Pool::atom(), Msg::mqtt_packet_map:mqtt_message(), PublisherContext::term()) -> ok

start_link(Pool::atom()) -> {ok, pid()} | {error, term()}

terminate(Reason, State) -> any()