anchor.diff:      end.
   
   handle_cast({send, Message, StartTime}, State=#state{messages=[]}) ->
  -    statsderl:timing_now(?STATE.statsd_latency_key_in, StartTime, 0.01),
  +    statsderl:timing_now(?STATE.statsd_latency_key_in, StartTime, 0.1),
       MessageLength = molderl_utils:message_length(0, Message),
       case MessageLength > ?PACKET_SIZE of
           true -> % Single message is bigger than packet size, log and exit!
  
positive.code:                            destination_port = DestinationPort,
                             timer_ref = erlang:send_after(ProdInterval, self(), prod),
                             prod_interval = ProdInterval,
                             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};
  
negative.code:             {noreply, ?STATE{message_length=MessageLength, messages=[Message], start_time=StartTime}}
      end;
  handle_cast({send, Message, StartTime}, State) ->
      statsderl:timing_now(?STATE.statsd_latency_key_in, StartTime, 0.1),
      % Can we fit this in?
      MessageLength = molderl_utils:message_length(?STATE.message_length, Message),
      case MessageLength > ?PACKET_SIZE of
  