anchor.diff:      {ok, NewState}.
   
   timeout(State=#state{}, InactiveMs) ->
  -    lager:info("session was inactive for ~p ms", [InactiveMs]),
  +    lager:debug("session was inactive for ~p ms", [InactiveMs]),
       {ok, State}.
   
   info(State=#state{}, Entry={entry, _Bucket, _Stream, #sblob_entry{}}) ->
  
positive.code:                       ok ->
                            % TODO
                            QosVal = ?QOS_0,
                            lager:info("Subscribe ~p ~p", [TopicName, Qos]),
                            iorio:subscribe(Bucket, Stream, self()),
                            {[QosVal|QosList], OState};
                        {error, Reason} ->
  
negative.code:                   {Bucket, Stream} = extract_bucket_and_stream(TopicName,
                                                                 Username,
                                                                 BucketSeparator),
                    lager:debug("Unsubscribe ~p", [TopicName]),
                    iorio:unsubscribe(Bucket, Stream, self()),
                    OState
            end,
  