Re: Output to input stream for streaming?

Reinhard Nägele Mon, 10 Aug 2009 06:12:48 -0700

You need to wait until your executor thread has finished. Then it mightwork.


Future<?> f = Executors.newSingleThreadExecutor().submit(new Runnable() {
     @Override
     public void run() {
       try {
         wb.write(out);
       } catch (IOException e) {
         MarkupUtils.handleUnexpectedException(e);
       }
     }
   });
f.get();




Erik van Oosten schrieb:

That won't work. Servlets are synchronous; they don't expect anyonewriting the output once the servlet finished.
Regards,
   Erik.


Russell Simpkins wrote:
Its not that anything is missing per se, but if you run your outputwriter in a separate thread, then the rest of your processing is freeto continue and in your case I'm guessing that the processing hasfinished before your output writing has completed. When your servletfinishes, the last thing that happens is the output stream getsclosed. Try doing the write outside of a thread and see if you getthe same exception.
Russ
Date: Mon, 10 Aug 2009 15:03:13 +0300
Subject: Re: Output to input stream for streaming?
From: martin.maku...@koodaripalvelut.com
To: users@wicket.apache.org

Well well.. I do not understand why it is not possible, in principle.
The input is there. The output is there... what's missing?

**
Martin

2009/8/10 Russell Simpkins <russellsimpk...@hotmail.com>:
Martin,
I don't think you can do this in a thread because that lets theHttpServletResponse end and close your ServletOutputStream.
Russ
Date: Mon, 10 Aug 2009 14:49:58 +0300
Subject: Output to input stream for streaming?
From: martin.maku...@koodaripalvelut.com
To: users@wicket.apache.org

Hi!

I have a HSSF document which can be written to an output stream.
However, I want to stream it to the website visitor, whichrequires aninputstream... I have tried the following, but it somehow doesn'tseem
to work.

Anybody know what can be done to fix it?

    final PipedInputStream inputStream = new PipedInputStream();
    final PipedOutputStream out;
    try {
      out = new PipedOutputStream(inputStream);
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
    Executors.newSingleThreadExecutor().execute(new Runnable() {
      @Override
      public void run() {
        try {
          wb.write(out);
        } catch (IOException e) {
          MarkupUtils.handleUnexpectedException(e);
        }
      }
    });

    IResourceStream resourceStream = new IResourceStream() {
      /**
       * @see org.apache.wicket.util.resource.IResourceStream#close()
       */
      public void close() throws IOException {
        inputStream.close();
      }

      /**
* @seeorg.apache.wicket.util.resource.IResourceStream#getContentType()
       */
      public String getContentType() {
        return getAlternateContentType();
      }

      /**
* @seeorg.apache.wicket.util.resource.IResourceStream#getInputStream()
       */
      public InputStream getInputStream()
          throws ResourceStreamNotFoundException {
        return inputStream;
      }

      /**
* @seeorg.apache.wicket.util.resource.IResourceStream#getLocale()
       */
      public Locale getLocale() {
        throw new IllegalAccessError("Method not implemented.");
      }

      /**
* @seeorg.apache.wicket.util.resource.IResourceStream#length()
       */
      public long length() {
        try {
          return inputStream.available();
        } catch (IOException e) {
          MarkupUtils.handleUnexpectedException(e);
        }
        return 0;
      }

      /**
* @seeorg.apache.wicket.util.resource.IResourceStream#setLocale(java.util.Locale)
       */
      public void setLocale(Locale locale) {
        throw new IllegalAccessError("Method not implemented.");
      }

      /**
* @seeorg.apache.wicket.util.watch.IModifiable#lastModifiedTime()
       */
      public Time lastModifiedTime() {
returnTime.milliseconds(DatabaseServices.getCurrentTimestamp().getTime());
      }

    };

java.io.IOException: Pipe closed
at java.io.PipedInputStream.checkStateForReceive(UnknownSource)
      at java.io.PipedInputStream.receive(Unknown Source)
      at java.io.PipedOutputStream.write(Unknown Source)
      at java.io.OutputStream.write(Unknown Source)
atorg.apache.poi.poifs.storage.BigBlock.doWriteData(BigBlock.java:55)atorg.apache.poi.poifs.storage.DocumentBlock.writeData(DocumentBlock.java:220)atorg.apache.poi.poifs.storage.BigBlock.writeBlocks(BigBlock.java:86)atorg.apache.poi.poifs.filesystem.POIFSDocument$BigBlockStore.writeBlocks(POIFSDocument.java:603)atorg.apache.poi.poifs.filesystem.POIFSDocument.writeBlocks(POIFSDocument.java:275)atorg.apache.poi.poifs.filesystem.POIFSFileSystem.writeFilesystem(POIFSFileSystem.java:390)atorg.apache.poi.hssf.usermodel.HSSFWorkbook.write(HSSFWorkbook.java:1168)
**
Martin



---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscr...@wicket.apache.org
For additional commands, e-mail: users-h...@wicket.apache.org

Re: Output to input stream for streaming?

Reply via email to