my $msg  = "";
    while( my $portaddr = recv($this->{in}, $msg, 1024, 0) ) {
        my ($portno, $ipaddr) = sockaddr_in($portaddr);
        my $ip = inet_ntoa($ipaddr);

        push @msgs, [$ip, $this->_transform($msg)];
    }