anchor.diff:                             destination_port = DestinationPort,
                              timer_ref = erlang:send_after(ProdInterval, self(), prod),
                              prod_interval = ProdInterval,
  -                           statsd_latency_key = "molderl." ++ atom_to_list(StreamName) ++ ".packet.latency",
  -                           statsd_count_key   = "molderl." ++ atom_to_list(StreamName) ++ ".packet.sent"
  +                           statsd_latency_key_in = "molderl." ++ atom_to_list(StreamName) ++ ".time.in",
  +                           statsd_latency_key_out = "molderl." ++ atom_to_list(StreamName) ++ ".time.out",
  +                           statsd_count_key   = "molderl." ++ atom_to_list(StreamName) ++ ".sent"
                             },
               {ok, State};
           {error, Reason} ->
  
positive.code:                  start_time,            % Start time of the earliest msg in a packet
                   prod_interval,         % Maximum interval at which either partial packets or heartbeats should be sent
                   timer_ref,             % reference to timer used for hearbeats and flush interval
                   statsd_latency_key,    % cache the StatsD key to prevent binary_to_list/1 calls and concatenation all the time
                   statsd_count_key       % cache the StatsD key to prevent binary_to_list/1 calls and concatenation all the time
                 }).
  
  
negative.code:     end.
  
  handle_cast({send, Message, StartTime}, State=#state{messages=[]}) ->
      statsderl:timing_now(?STATE.statsd_latency_key_in, StartTime, 0.01),
      MessageLength = molderl_utils:message_length(0, Message),
      case MessageLength > ?PACKET_SIZE of
          true -> % Single message is bigger than packet size, log and exit!
  