Kevin Earls created AMQ-5093:
--------------------------------
Summary: ampq with nio or nio+ssl fails when sending large messages
Key: AMQ-5093
URL: https://issues.apache.org/jira/browse/AMQ-5093
Project: ActiveMQ
Issue Type: Bug
Reporter: Kevin Earls
Assignee: Kevin Earls
This can be reproduced with the test case shown below, which I will add to
JMSClientTest.
public void testSendLargeMessage() throws JMSException, InterruptedException {
Connection connection = createConnection();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
String queueName = name.toString();
Queue queue = session.createQueue(queueName);
MessageProducer producer=session.createProducer(queue);
int messageSize = 1024 * 1024;
String messageText = createLargeString(messageSize);
Message m=session.createTextMessage(messageText);
LOG.debug("Sending message of {} bytes on queue {}", messageSize,
queueName);
producer.send(m);
MessageConsumer consumer=session.createConsumer(queue);
Message message = consumer.receive();
assertNotNull(message);
assertTrue(message instanceof TextMessage);
TextMessage textMessage = (TextMessage) message;
LOG.debug(">>>> Received message of length {}",
textMessage.getText().length());
assertEquals(messageSize, textMessage.getText().length());
assertEquals(messageText, textMessage.getText());
}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
