anchor.diff:                        ok ->
                             % TODO
                             QosVal = ?QOS_0,
  -                          lager:info("Subscribe ~p ~p", [TopicName, Qos]),
  +                          lager:debug("Subscribe ~p ~p", [TopicName, Qos]),
                             iorio:subscribe(Bucket, Stream, self()),
                             {[QosVal|QosList], OState};
                         {error, Reason} ->
  
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:                   {Bucket, Stream} = extract_bucket_and_stream(TopicName,
                                                                 Username,
                                                                 BucketSeparator),
                    lager:debug("Unsubscribe ~p", [TopicName]),
                    iorio:unsubscribe(Bucket, Stream, self()),
                    OState
            end,
  