"Piping" streams in Java
I have a Lucene-based application that indexes e-mails. The content handler for HTML e-mail has gone through various incarnations now, but I'm settling on putting the dirty HTML message parts into org.ccil.cowan.tagsoup.Par
However, it isn't very elegant using a Writer to write to a temporary file and then a Reader to read all the content from it immediately afterwards. The Lucene interface demands that I present it with a class which extends java.io.Reader. Do you reckon there's a practicable way to extend java.io.Reader to read from a org.xml.sax.ContentHandler
However, it isn't very elegant using a Writer to write to a temporary file and then a Reader to read all the content from it immediately afterwards. The Lucene interface demands that I present it with a class which extends java.io.Reader. Do you reckon there's a practicable way to extend java.io.Reader to read from a org.xml.sax.ContentHandler
ASKER CERTIFIED SOLUTION
membership
This solution is only available to members.
To access this solution, you must be a member of Experts Exchange.
Mayank S
You could try StringWriter/ StringReader if you don't want to create temporary files.
ASKER
Perfect! Another one I owe you, CEHJ :-)
[mayankeagle, I need to be a good citizen with respect to heap usage in my container. The PipedReader is what I needed - I just hadn't figured out that I needed a separate thread for reading from the stream as and when data became available from the SAX events.]
[mayankeagle, I need to be a good citizen with respect to heap usage in my container. The PipedReader is what I needed - I just hadn't figured out that I needed a separate thread for reading from the stream as and when data became available from the SAX events.]
:-)
If you find out about that 'bug' let me know here ;-)
If you find out about that 'bug' let me know here ;-)
ASKER
main() completes before run has completed its course? My guess is you need to join the PipedReader thread to wait for it to complete. I'll experiemnt to see.
ASKER
It works nicely for me if I close the writer to get the EOF and then use join to wait for the PipedReader thread to complete.
i.e.
--------8<--------
out = new PrintWriter(pw, true);
Thread t = new Thread() {
/* ... */
};
t.start();
// Parses an XML file using a SAX parser.
parseXmlFile(
//"file:/C:/Documents and Settings/Charles/workspace
"file:/"+filename,
handler, false);
try {
out.close(); // Close the output stream to get the PipedReader to see EOF
t.join(); // Wait for the PipedReader to finish before exiting main
} catch (InterruptedException e) {
e.printStackTrace();
}
--------8<--------
i.e.
--------8<--------
out = new PrintWriter(pw, true);
Thread t = new Thread() {
/* ... */
};
t.start();
// Parses an XML file using a SAX parser.
parseXmlFile(
//"file:/C:/Documents and Settings/Charles/workspace
"file:/"+filename,
handler, false);
try {
out.close(); // Close the output stream to get the PipedReader to see EOF
t.join(); // Wait for the PipedReader to finish before exiting main
} catch (InterruptedException e) {
e.printStackTrace();
}
--------8<--------
Thanks rstaveley - well done