anchor.diff:                                 fun(R) -> {unbind, R, {queue, Queue}} end,
                                  ?TOPIC_MASTER).
   
  +-spec bindings(binary()) -> {ok, [{queue, binary()}]}.
  +%% @doc
   bindings(Topic) ->
       harbinger_coordinator:reply({Topic, Topic},
                                   harbinger_topic,
  
positive.code: %% Types
  %%
  
  -record(s, {partition,
              head = 0                   :: non_neg_integer(),
              tail = 0                   :: non_neg_integer(),
              bindings = gb_sets:empty() :: gb_set()}).
  
  -define(TIMEOUT, 5000).
  
  
negative.code: 
  -spec publish(binary(), binary()) -> ok.
  %% @doc
  publish(Topic, Payload) ->
      harbinger_coordinator:noreply({Topic, Topic},
                                 harbinger_topic,
                                 fun(R) -> {publish, R, Payload} end,
                                 ?TOPIC_MASTER).
  
  -spec bind(binary(), binary()) -> {ok, non_neg_integer(), non_neg_integer()}.
  %% @doc
  