Extreme.SubscriptionsSupervisor (extreme v1.1.4)

View Source

Summary

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor.

init(atom)

Callback implementation for DynamicSupervisor.init/1.

kill_all_subscriptions(base_name)
start_link(base_name)
start_persistent_subscription(base_name, correlation_id, subscriber, stream, group, allowed_in_flight_messages)
start_reading_subscription(base_name, correlation_id, subscriber, read_params)
start_subscription(base_name, correlation_id, subscriber, stream, resolve_link_tos, ack_timeout \\ 5000)
stop_subscription(base_name, pid)

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

init(atom)

Callback implementation for DynamicSupervisor.init/1.

kill_all_subscriptions(base_name)

start_link(base_name)

start_persistent_subscription(base_name, correlation_id, subscriber, stream, group, allowed_in_flight_messages)

start_reading_subscription(base_name, correlation_id, subscriber, read_params)

start_subscription(base_name, correlation_id, subscriber, stream, resolve_link_tos, ack_timeout \\ 5000)

stop_subscription(base_name, pid)