Attachment 847589 Details for Bug 1050937 – reproducer

reproducer

LargeMessageTest.java (text/x-java), 1.70 KB, created by Gordon Sim on 2014-01-09 11:34:55 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Gordon Sim

Created: 2014-01-09 11:34:55 UTC

Size: 1.70 KB

patch

obsolete

>package org.apache.qpid.amqp_1_0.jms.example;
>
>import javax.jms.*;
>import javax.naming.Context;
>import javax.naming.InitialContext;
>import java.util.*;
>import org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl;
>
>public class LargeMessageTest
>{
>    public static void main(String[] args) throws Throwable
>    {
>        int size = 1024*1024;
>        byte[] data = new byte[size];
>        Random rand = new Random(System.nanoTime());
>        rand.nextBytes(data);
>        Connection conn = new ConnectionImpl("127.0.0.1",5672,"guest","guestPassword","testproducer");
>        Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
>        javax.jms.Queue queue = session.createQueue("queue");
>        MessageProducer prod = session.createProducer(queue);
>        prod.setDeliveryMode(DeliveryMode.PERSISTENT);
>        BytesMessage persistentMsg = session.createBytesMessage();
>        persistentMsg.writeBytes(data);
>        prod.send(persistentMsg);
>        conn.start();
>        conn.close();
>        conn = new ConnectionImpl("127.0.0.1",5672,"guest","guestPassword","testconsumer");
>        conn.setExceptionListener(new ExceptionListener() {
>            @Override
>            public void onException(JMSException exception) {
>                exception.printStackTrace();
>            }
>        });
>        Session session1 = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
>        MessageConsumer cons = session1.createConsumer(session1.createQueue("queue"));
>        conn.start();
>        BytesMessage received = (BytesMessage) cons.receive();
>        final byte[] recvData = new byte[size];
>        received.readBytes(recvData);
>        System.err.println(Arrays.equals(data, recvData));
>        conn.close();
>    }
>}

Actions: View

Attachments on bug 1050937: 847589