OpenAperture.Builder.MessageManager

This module contains the logic for associating message references with their subscription handlers

Summary↑

remove(delivery_tag)

Method to stop tracking a delivered message

start_link()

Creates a GenServer representing Docker host cluster

track(async_info)

Method to start tracking a delivered message

Functions

remove(delivery_tag)

Specs:

Method to stop tracking a delivered message

Options

The delivery_tag option is the unique identifier of the message

Return Value

Map containing the subscription_handler and delivery_tag

start_link()

Specs:

  • start_link :: {:ok, pid} | {:error, String.t}

Creates a GenServer representing Docker host cluster.

Return values

{:ok, pid} | {:error, String.t()}

track(async_info)

Specs:

  • track(Map) :: term

Method to start tracking a delivered message.

Options

The _async_info is a Map containing the following entries:

  • :subscription_handler
  • :delivery_tag