gistfile1.pl

sub add {
  my ($self, $window_id, $message) = @_;

  AnyEvent::HTTP::http_request
    POST => "$self->{url}/buckets/$window_id",
    body => encode_json($message),
    headers => {
      "x-riak-index-msgid_int"     => $message->{msgid},
      "x-riak-index-nick_bin"      => lc $message->{nick},
      "x-riak-index-timestamp_int" => $message->{timestamp},
    },
    sub {
      my ($body, $headers) = @_;
      if ($headers->{Status} != 200) {
        warn $body;
      }
    };
}