Large message lost packets

[the.finder1]

Hi guys,
I send a long string through BytesMessage, but received wrong message.
Sender program:
{code:java}
// here s is a large string and s.length() = 1040824
BytesMessage message = session.createBytesMessage();
ByteArrayInputStream bis = new ByteArrayInputStream(s.getBytes("UTF-8"));
BufferedInputStream is = new BufferedInputStream(bis);
message.setObjectProperty("JMS_HQ_InputStream", is);
producer.send(message);
{code}
 
Receiver program:
{code:java}
ByteArrayOutputStream bos = new ByteArrayOutputStream();
BufferedOutputStream os = new BufferedOutputStream(bos);
((BytesMessage) message).setObjectProperty("JMS_HQ_SaveStream", os);
String s = new String(bos.toByteArray(), "UTF-8");
// here received s.length() = 1036062
{code}
 
The min-large-message-size is configured 1048576 in hornetq-jms.xml.
When I change min-large-message-size to 2000000, it's ok.
Is it a bug?

[clebert.suconic]

Do you see any logging on server/client?

I have tried replicating your program here, and I couldn't get any failures.

One thing though.. I'm not sure why you're using a BufferedInputStream, since the ByteArray is already complete.

You usually need a BufferedStream when dealing with reading files or sockets to avoid extra calls to the OS resource.

[the.finder1]

Thanks Clebert, I remove codes about BufferedInputStream and BufferedOutputStream, everything got OK.

I will take more time to find why.

[timfox]

The bug is in your code. You don't flush the ByteArrayOutputStream before retrieving the String.