[jira] Commented: (AMQ-1012) Receiving a BytesMessage sent from Java using CMS listener causes exception thrown in class BufferedInputStream

["Nathan Mittler (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/activemq/browse/AMQ-1012?page=comments#action_37339 ] 
            
Nathan Mittler commented on AMQ-1012:
-------------------------------------

This appears to be a broker issue.  When the c++ client gets the exception, it's detecting there is data on the socket and goes to read it but nothing's there - a typical sign of a broken socket.   So the question now is: what's going on at the broker side of things when it tries to bridge the bytes message from JMS to stomp that it breaks the socket?  Is it hitting an exception, perhaps?  I'm going to dig around in the broker code and see if I can find anything.

> Receiving a  BytesMessage sent from Java using CMS listener causes exception thrown in class BufferedInputStream
> ----------------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-1012
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1012
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: CMS (C++ client)
>    Affects Versions: 4.0.2
>         Environment: Ubuntu Linux 6.06 LTS, ActiveMQ 4.0.2, CMS version 0.0.2 with STOMP
>            Reporter: Mark Silberbauer
>             Fix For: 4.0.3
>
>   Original Estimate: 1 day
>  Remaining Estimate: 1 day
>
> 1) Setup a MessageListener to listen for messages on Topic X using CMS.
> 2) Send a BytesMessage from ActiveMQ java JMS interface to Topic X
> 3) An exception is thrown from BufferedInputStream::bufferData() with description "failed reading bytes from stream""
>     int bytesRead = stream->read( buffer+tail, bufferSize-tail );
>     if( bytesRead == 0 ){
>         throw IOException( __FILE__, __LINE__, 
>             "BufferedInputStream::read() - failed reading bytes from stream");
>     }
> 4) The operation of the CMS interface is broken thereafter.
> Note:
> This only occurs when sending a BytesMessage from Java to C++
> Sending a BytesMessage from C++ to Java or  C++ to C++ works perfectly.
> Sending messages of Type TextMessage also works perfectly.

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira