Module mqtt_sessions_job

publish(Pool::atom(), Topic::mqtt_sessions:topic(), Routes::list(), Msg::mqtt_packet_map:mqtt_message(), PublisherContext::term()) -> {ok, pid() | undefined} | {error, overload}

publish1(Pool, Topic, Route, Msg, PublisherContext, PublisherPid) -> any()

publish_job(Pool, Topic, Routes, Msg, PublisherContext, PublishedPid) -> any()

publish_retained(Pool::atom(), TopicFilter::mqtt_sessions:topic(), Ms::list(), Subscriber::mqtt_sessions:callback(), Options::map(), SubscriberContext::term()) -> ok | {error, overload}

publish_retained_job(Pool::atom(), TopicFilter::mqtt_sessions:topic(), Ms::list(), Subscriber::mqtt_sessions:callback(), Options::map(), SubscriberContext::term()) -> ok