anchor.diff:  	 case file:read(DataFile,3) of
       	{ok,<<3,3,3>>} -> lager:info("Last message found at ~p in ~p, truncating file...",[Offset,FileName]),
       					  file:truncate(DataFile);
  -    	_Data          -> fix_file(DataFile,NewOffset,FileName)
  +    	Data           -> fix_file(DataFile,NewOffset,FileName)
       end.
   
   
  
positive.code: 	after 5000 ->
  		% Routine maintenance 
  		erlang:garbage_collect(),
                  loop(Writer,DataList,ClearToSend,LastTS,Count,StreamName)
  	end.
  
  
  
negative.code: 	loop(Writer,[],true,0,0,Stream).
  
  loop(Writer,DataList,ClearToSend,LastTS,Count,StreamName) ->
  	receive
  		Message ->
  			case Message of 
  