Lost messages while reading a pipefile using java

Hi,
I have this weirdest problem...

I am using unix pipefiles to communicate between programs.

The program runs fine, only out of 200000! msgs dayly, I loose about 15.

With lost I mean:
I see this in the log of the sending program:

send2pipe : 12456478798|#|TBB|#||#|363|#|28186|#|2818600|#|400|#|0|#|N|#|JT|#|N|#|P|#||#||#||#|16|#|5|#||#|0.000000|#|26941549169310|#||#||#||#|1|#|TBB|#|N|#|2814400|#|01152|#|0|#|N|#|Y|#||#||#|END successfully passed to fifo

I see nothing in the log of the receiving program.  While the receiving program writes out the message on the very first occasion after the read.

This is very odd if you keep in mind, that a pipefile that is not read out, blocks the writing program.  But that isn't happening, the writing program says the pipe has been read.  But there is no sign of the message however in the reading program.  Also no error or whatsover.

Any hint on where those messages go would be awsome...


Here are the program snippets:

On unix I create a pipe like this:

mkfifo /data/pipe/pipefileToJava

Then in a script I write to the pipefile like this:

  echo send2pipe : sending stream $Payload to $PipeFile
  echo $Payload >  $PipeFile &
  sleep 1

    if kill %1 >/dev/null 2>&1
    then
        echo send2pipe : could not connect to pipe
    else
        echo send2pipe : "$Payload" successfully passed to fifo
        exit 0
    fi

Then in Java I read the pipefile in a loop like this:
It opens the file:

               fr=new FileReader(s_named_pipe_path);
               br=new BufferedReader(fr);

The java code 'hangs' on the 

br.readLine()

Until there is a message.  It reads it, logs it.

logger.info("Retrieving a message ..." + line);

And it closes the file:

fr.close(); 

br.close();

Then it goes to the top of the loop, to reopen the pipefile.
I close and reopen the pipefile everytime, otherwise I do not have that 'hanging/sleeping' waiting for message effect on the pipefile.

         while(continueProcessing)
         {
               fr=new FileReader(s_named_pipe_path);
               br=new BufferedReader(fr);
               
               while((line=br.readLine())!=null)
               {  
                   logger.info("Retrieving a message (count since start: "+ (NumberMessagesReceived++) + ") from named pipe: " + s_named_pipe_path + ": " + line);
               }
               if(fr!=null)
               {
                  logger.info("Closing file reader");
                  fr.close();  
               }
               if(br!=null)
               {
                  logger.info("Closing buffered reader");
                  br.close();
               }  
}