sub processMessages
{
    my ($this) = @_;

    my $endTime  = time + $ENV{'MAX_LIFETIME'};

    select STDOUT; 
    $|++;  # make unbuffered
    
    my $select = IO::Select->new();
    $select->add(\*STDIN);
   
    my $messageDelimiter    = $this->_messageDelimiter();
 
    my $delimiterMatch    = qr{\n$messageDelimiter$};
  
    my $frozenMessage;
    my $messageToProcess    = {};
    my $stopNow    = 0;
    while(time < $endTime)
    {
        my $offset;
    
        my ($handle) = $select->can_read(5);

        my $previousRead;
        while(
            ($handle)
            &&
            (my $bytes = $handle->sysread($frozenMessage, 8192, $offset))
        )
        {
            $offset += $bytes;

            ## Because Storable may put newlines in the frozen object, 
            ## delimit messages:
            my $searchableText    = $previousRead . $frozenMessage;
            if($searchableText =~ /$delimiterMatch/)
            {
    
                $frozenMessage  =~ s/$delimiterMatch//;
                $messageToProcess = thaw($frozenMessage);
    
            }

            $previousRead = $frozenMessage;

            if(%$messageToProcess)
            {

                ### DO MESSAGE PROCESSING HERE ##

                my $outputMessage;
                if($processor->hasErrors())
                {
                    my $errors = $processor->getErrors();
            
                    $outputMessage = qq|$$ ERROR $errors->[0]\n|;
            
                }
                else
                {
                    my $messageID = $processor->lastMessageID(); 
                    $outputMessage = qq|$$ SUCCESS $messageID\n|;
                }
    
                ## Write status back to the parent
                print STDOUT $outputMessage;

                $offset = 0;
    
                undef($frozenMessage);
                undef($previousRead);
                undef(%$messageToProcess);

           }
        }
    }
    
}