How can I get a handle to an InputStream my SimpleProcessor class extension?

The web-based interface is old... But so far, the mailing-list has seemed to work, mostly ;-) It also seems that your message with the attachment made it to the list. You can also do a lot through Nabble:

http://www.nabble.com/How-can-I-get-a-handle-to-an-InputStream-my-SimpleProcessor-class-extension--td18851540.html

Not sure if we should migrate at this point. Migrating is also quite a pain. Updating to Nabble 2 would also be an option to make the list appear smoother to the outside world.

-Erik

On Sep 5, 2008, at 3:48 AM, Henrik Pettersen wrote:

All,

this mailing list software is giving me gray hairs. Either I don't
receive my own postings, or attachments means an automatic quarantine.
I've tried modifying my mailing list settings at
http://www.objectweb.org/wws/suboptions/ops-users, without having any
luck: I've set the receiving option to 'standard(direct receiption)',
but the help menu next to it does not contain any information on this
menu option, as far as I can see.

Why not use something like Google Groups or Yahoo Groups? Your current
mailing list software does look a bit like it's 1998 ;-)

My 2 cents :-)

Henrik

2008/9/4 Henrik Pettersen <[hidden email]>:

All,

I've finally come up with a solution for this problem, which should
work for general cases. If you ever find yourself wanting to get a
handle to an inputstream of the input data in your SimpleProcessor
extension, this should work.

Please find attached:
1. A new class containing the implementation of this solution
(StreamingSimpleProcessorBase.java)
2. A template class showing how to roll your own SimpleProcessor
extensions with access to an InputStream of any input
(StreamingProcessorTemplate)

The documentation and implementation details has been marked up with
Javadoc, which I've put up here:
http://sparklingideas.co.uk/orbeon/streaming/StreamingProcessorTemplate.html
http://sparklingideas.co.uk/orbeon/streaming/StreamingSimpleProcessorBase.html

You will most likely have to refactor the package structure, and the
javadoc does not provide any links to any other libraries, classes and
methods.

Any comments, suggestions, or bugs found are welcome.

Hope this will be useful for someone else out there!

Sincerely,
Henrik Pettersen

2008/8/15 Henrik Pettersen <[hidden email]>:

Erik, Alessandro,

thank you, this makes a lot of sense to me.

I can see how you may write the contents to a local file and open up a
new inputstream to this, or do something fancy with threads, possibly
using Java pipes.

However, I've decided to overcome this problem by exposing my java
functionality as a REST webservice, and calling this using:

 <p:processor name="oxf:xforms-submission">
     <p:input name="submission">
         <xforms:submission method="put"
action="http://localhost:8080/timmy/import"/>
     </p:input>
     <p:input name="request" href="#escenicXml" />
     <p:output name="response" ref="data" />
 </p:processor>

The REST webservice is exposed through a custom Servlet. Here is the
servlet definition from web.xml:

 <servlet>
     <servlet-name>timmy</servlet-name>
     <servlet-class>com.telegraph.online.timmy.rest.ImportServlet</servlet-class>
 </servlet>
 <servlet-mapping>
     <servlet-name>timmy</servlet-name>
     <url-pattern>/import</url-pattern>
 </servlet-mapping>

Please find the source for the Servlet attached.

By defining a REST API like this, and calling this from my pipeline
over HTTP. I'm able to get my handle on the inputstream (see
ImportServlet, attached):
... (new ImportAction()).doImport(request.getInputStream());

This, I hope, should work, and should achieve the transformation from
a push architecture (Orbeon), to a pull architecture (Servlet).

Thank you, everyone!

Sincerely,
Henrik Pettersen


On Fri, Aug 8, 2008 at 12:14 AM, Erik Bruchez <[hidden email]> wrote:

getContentAsStream() is the resource manager is something different:
it reads a file from disk and returns a stream of bytes for this file.
As Florent mentioned, what flows between processors is XML in the form
of SAX events. So at that stage, the XML has already been parsed. It
would be best if your library could provide a SAX ContentHandler, into
which you can send the SAX events with readInputAsSAX(). Otherwise you
will have to serialize the XML so you can get a InputStream.

The issue comes from the fact that SAX will push the content, while your API
which expects an InputStream excpects to pull the content. In general, with
this kind of situations, you either need two threads, or you need to first
read the content into a temporary location.

You would need something similar to NetUtils.inputStreamToAnyURI(), except:

* you would read a SAX stream and serialize it into the temporary file item
* you would then pass the file item's InputStream to your API

-Erik

--
Orbeon Forms - Web Forms for the Enterprise Done the Right Way
http://www.orbeon.com/



--
You receive this message as a subscriber of the [hidden email] mailing
list.
To unsubscribe: mailto:[hidden email]
For general help: mailto:[hidden email]?subject=help
OW2 mailing lists service home page: http://www.ow2.org/wws

--
You receive this message as a subscriber of the [hidden email] mailing list.
To unsubscribe: mailto:[hidden email]
For general help: mailto:[hidden email]?subject=help
OW2 mailing lists service home page: http://www.ow2.org/wws

--
Orbeon Forms - Web Forms for the Enterprise Done the Right Way
http://www.orbeon.com/

--
You receive this message as a subscriber of the [hidden email] mailing list.
To unsubscribe: mailto:[hidden email]
For general help: mailto:[hidden email]?subject=help
OW2 mailing lists service home page: http://www.ow2.org/wws