Hi Marnie, Thanks for your prompt response. yes i tried to wait before consuming, and it worked for me. But the practical issue is we are sending and consuming concurrently in two different threads, I think if the consumer assume there's a message in the queue before it successfully stored in to Qpid, that is not correct.
I believe there's an issue in Qpid Java client consumer implementation. I will look in to transaction work and get back to the thread. WDYT ? Regards Lahiru On Fri, Nov 26, 2010 at 8:27 PM, Marnie McCormack < [email protected]> wrote: > If the whole message hasn't been buffered on the broker before you try to > consume it then this might account for this exception. Try sleeping before > consuming and see if the issue goes away, that'd prove it - or use > transactions on the send() and wait for commit to return before consuming ? > > Marnie > > On Fri, Nov 26, 2010 at 2:50 PM, Lahiru Gunathilake <[email protected] > >wrote: > > > Hi Marnie, > > > > On Fri, Nov 26, 2010 at 6:23 PM, Marnie McCormack < > > [email protected]> wrote: > > > > > Hi Lahiru, > > > > > > There's a JIRA about this exception/issue - QPID-2902. > > > > > > Does it fail for you reliably ? I wonder if there's a timing issue here > > > since it didn't occur all the time on the CI instance. > > > > > +1, I noticed some of the messages were picked successfully. I think this > > is > > a timing issue comes due to large sizes of the messages. > > > > Lahiru > > > > > > > > Marnie > > > > > > On Fri, Nov 26, 2010 at 12:14 PM, Lahiru Gunathilake < > [email protected] > > > >wrote: > > > > > > > Hi Devs, > > > > > > > > When I consume a big message with 1MB file size and pick it from Qpid > > > > Queue, > > > > I am getting an error like this > > > > > > > > avax.jms.JMSException: Could not decode string data: > > > > java.nio.charset.MalformedInputException: Input length = 1<br> at > > > > > > > > > > > > > > org.apache.qpid.client.message.JMSTextMessage.getText(JMSTextMessage.java:150) > > > > > > > > After debugging the code, I feel like this happen, due to a malformed > > > input > > > > stream coming for the client. > > > > > > > > Can I increase the frame-size of the client and get this message in > to > > a > > > > single frame ? Is there any other solution to this error. > > > > > > > > Regards > > > > Lahiru > > > > > > > > > >
