anchor.diff:  publish(State=#state{username=Username, bucket_separator=BucketSeparator,
                        access=Access},
           {Topic, Qos, Dup, Retain, MessageId, Payload}) ->
  -    lager:info("Publish ~p ~p ~p ~p ~p ~p",
  +    lager:debug("Publish ~p ~p ~p ~p ~p ~p",
                  [Topic, Qos, Dup, Retain, MessageId, Payload]),
       {Bucket, Stream} = extract_bucket_and_stream(Topic, Username,
                                                    BucketSeparator),
  
positive.code:     lists:foreach(SendEntry, Entries),
      {ok, State};
  info(State=#state{}, {smc, {heartbeat, Props}}) ->
      lager:info("smc heartbeat ~p", [Props]),
      {ok, State};
  info(State=#state{}, {smc, Info}) ->
      lager:info("channel update for ~p: ~p", [self(), Info]),
      {ok, State};
  info(State=#state{}, Msg) ->
      lager:info("received unknown info message '~p'", [Msg]),
      {ok, State}.
  
  stop(State=#state{}) ->
      lager:info("stop"),
      {ok, State}.
  
  terminate(State=#state{}, Reason) ->
      lager:info("terminate ~p", [Reason]),
      {ok, State}.
  
  login(State, {Username, Password}) when is_list(Username) ->
  
negative.code:     {ok, NewState}.
  
  timeout(State=#state{}, InactiveMs) ->
      lager:debug("session was inactive for ~p ms", [InactiveMs]),
      {ok, State}.
  
  info(State=#state{}, Entry={entry, _Bucket, _Stream, #sblob_entry{}}) ->
  