[jira] [Created] (AMQ-5093) ampq with nio or nio+ssl fails when sending large messages

["Kevin Earls (JIRA)" <ji...@apache.org>]

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)