|
»
« Return to Thread: Asynchronous transport for permanent connections
Re: Asynchronous transport for permanent connections
by Marco D'Alia
::
Rate this Message:
Hi Ben,
I'm sorry but that feature isn't working, in the first revision in the
svn repository you can find an utility class that fix some problem in
the Mina's StreamIoHandler and some tests transport for streaming.
I've not continued that feature for my lack of understanding of the Mule
stream support ( getStreamMessageAdapter and the meaning of the
OutputStream parameter of routeMessage).
Beware that the StreamIoHandler allocate a bytebuffer with ALL the data
in the stream, I think that the only way to implement streaming is to
use messageSent method in the ServerHandler to keep the bytebuffer full.
Ben Hood ha scritto:
> Hi Marco,
>
> Interesting work!
>
>
>> This can be useful not only for long lasting/permanent
>> connections, but also to send large quantities of data,
>> streaming and push protocols.
>>
>
> How have you found streaming to work with the MINA API?
>
> I was looking at the class HttpServerConnection from your transport to
> find out how you are passing off a stream to a Mule component and if I'm
> not wrong, this is using the HttpResponse class from the mule http
> transport.
>
> Doesn't this materialize the stream before passing it on to the actual
> processing component?
>
> Cheers,
>
> Ben
>
>
>
> *****************************************************
>
> You can find us at www.voca.com
>
> *****************************************************
> This communication is confidential and intended for
> the exclusive use of the addressee only. You should
> not disclose its contents to any other person.
> If you are not the intended recipient please notify
> the sender named above immediately.
>
> Registered in England, No 1023742,
> Registered Office: Voca Limited
> Drake House, Three Rivers Court,
> Homestead Road, Rickmansworth,
> Hertfordshire, WD3 1FX
>
>
> This message has been checked for all email viruses by MessageLabs.
>
> ---------------------------------------------------------------------
> To unsubscribe from this list please visit:
>
> http://xircles.codehaus.org/manage_email
>
>
>
---------------------------------------------------------------------
To unsubscribe from this list please visit:
http://xircles.codehaus.org/manage_email
I'm sorry but that feature isn't working, in the first revision in the
svn repository you can find an utility class that fix some problem in
the Mina's StreamIoHandler and some tests transport for streaming.
I've not continued that feature for my lack of understanding of the Mule
stream support ( getStreamMessageAdapter and the meaning of the
OutputStream parameter of routeMessage).
Beware that the StreamIoHandler allocate a bytebuffer with ALL the data
in the stream, I think that the only way to implement streaming is to
use messageSent method in the ServerHandler to keep the bytebuffer full.
Ben Hood ha scritto:
> Hi Marco,
>
> Interesting work!
>
>
>> This can be useful not only for long lasting/permanent
>> connections, but also to send large quantities of data,
>> streaming and push protocols.
>>
>
> How have you found streaming to work with the MINA API?
>
> I was looking at the class HttpServerConnection from your transport to
> find out how you are passing off a stream to a Mule component and if I'm
> not wrong, this is using the HttpResponse class from the mule http
> transport.
>
> Doesn't this materialize the stream before passing it on to the actual
> processing component?
>
> Cheers,
>
> Ben
>
>
>
> *****************************************************
>
> You can find us at www.voca.com
>
> *****************************************************
> This communication is confidential and intended for
> the exclusive use of the addressee only. You should
> not disclose its contents to any other person.
> If you are not the intended recipient please notify
> the sender named above immediately.
>
> Registered in England, No 1023742,
> Registered Office: Voca Limited
> Drake House, Three Rivers Court,
> Homestead Road, Rickmansworth,
> Hertfordshire, WD3 1FX
>
>
> This message has been checked for all email viruses by MessageLabs.
>
> ---------------------------------------------------------------------
> To unsubscribe from this list please visit:
>
> http://xircles.codehaus.org/manage_email
>
>
>
---------------------------------------------------------------------
To unsubscribe from this list please visit:
http://xircles.codehaus.org/manage_email
« Return to Thread: Asynchronous transport for permanent connections
| Free embeddable forum powered by Nabble | Forum Help |
