anchor.diff:  
   test_offline_retro_basic(PublisherSock) ->
     Socket = kraken_client:new_client(),
  -  %% Buffer some messages so we dont just fail automatically
  -  ok = kraken_client:publish(PublisherSock,
  -    [{[<<"other">>], <<"dummy1">>},
  -      {[<<"other">>], <<"dummy2">>},
  -      {[<<"other">>], <<"dummy3">>},
  -      {[<<"other">>], <<"dummy4">>},
  -      {[<<"other">>], <<"dummy5">>},
  -      {[<<"other">>], <<"dummy6">>},
  -      {[<<"other">>], <<"dummy7">>}]),
     Horizon = kraken_client:get_horizon(Socket),
     log4erl:warn("Horizon ~p", [Horizon]),
     ok = kraken_client:publish(PublisherSock,
  
positive.code:     {<<"t1">>,<<"msg2">>}, {<<"t2">>,<<"msg1">>}], Socket),
    ok.
  
  -endif.
  
negative.code: 
  test_retro_basic(PublisherSock) ->
    Socket = kraken_client:new_client(),
    kraken_client:register(Socket),
    ok = kraken_client:publish(PublisherSock, 
                               [{[<<"t1">>, <<"t2">>, <<"other">>], <<"msg1">>},
  