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

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

     [ https://issues.apache.org/jira/browse/AMQ-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kevin Earls resolved AMQ-5093.
------------------------------

    Resolution: Fixed

Fixed with commit 87420cc455f6e02d5249bfe29b105f4e1e345969

> 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)