anchor.diff:          {ok, ?MESSAGE_HEADER} ->
               case file:read(DataFile, Size+3) of
                   {ok,?MESSAGE} -> case CRC32 == erlang:crc32(Data) of
  -                                                true -> retrieve_data(Operation, DataFile, FoundData, ConditionList, ?MESSAGE_PACKAGE)
  +                                                true -> retrieve_data(Operation, DataFile, FoundData, ConditionList, ?MESSAGE_PACKAGE);
                                                   false -> ok = file:close(DataFile),
                                                            lager:warning("Message: CRC32 Checksum failed on ~p", [TS]),
                                                            FoundData
  
positive.code: %% Thoughs on defining MESSAGE_PACKAGE as [?MESSAGE_HEADER, ?MESSAGE] or <<?MESSAGE_HEADER, ?MESSAGE>> for evolution.
  %% At this time, only TS, Size and Data are necessary for operation functions.
  %% CRC32 is processed at an upper level.
  -define(MESSAGE_PACKAGE, [TS:64/native-integer, Size:32/native-integer, Data:Size/binary]).
  
  
  
  
negative.code:     DataFile.
  
  retrieve_data(Operation, StreamID, ConditionList) ->
      [At | _] = ConditionList,
      DataFile = retrieve_data_init(StreamID, At),
      FoundData = retrieve_data(Operation, DataFile, [], ConditionList),
      list_to_binary(lists:flatten(lists:reverse(FoundData)))
      .
  
  retrieve_data_init(StreamID, At) ->
      {ok, File} = cake_stream_manager:stream_filename(StreamID),
      Offset = get_indexed_offset(StreamID, At),
      lager:debug("Offset from get_indexed_offset: ~p", [Offset]),
  