anchor.diff:              {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.01),
       % Can we fit this in?
       MessageLength = molderl_utils:message_length(?STATE.message_length, Message),
       case MessageLength > ?PACKET_SIZE of
  
positive.code:                            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"
                            },
              {ok, State};
          {error, Reason} ->
  
negative.code:     MsgPkt = molderl_utils:gen_messagepacket(?STATE.stream_name, ?STATE.sequence_number, lists:reverse(?STATE.messages)),
      {NextSequence, EncodedMessage, MessagesWithSequenceNumbers} = MsgPkt,
      ok = gen_udp:send(?STATE.socket, ?STATE.destination, ?STATE.destination_port, EncodedMessage),
      statsderl:timing_now(?STATE.statsd_latency_key_out, ?STATE.start_time, 0.01),
      statsderl:increment(?STATE.statsd_count_key, 1, 0.01),
      {NextSequence, MessagesWithSequenceNumbers}.
  
  