Producer

import java.math.BigInteger;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Random;
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;


public class Producer
{

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws NoSuchAlgorithmException
    {
        if (args.length != 1)
        {
            System.out.println("ARGUMENTS: conectionString (tcp://host:port)");
        }
        else
        {
            ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(args[0]);

            try
            {
                Connection conn = factory.createConnection();
                conn.start();
                Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
                Destination q = session.createQueue("DATA");
                MessageProducer producer = session.createProducer(q);

                byte[] body = new byte[1048576]; //1MB message
                new Random().nextBytes(body);

                producer.setDeliveryMode(DeliveryMode.PERSISTENT);
                BytesMessage msg = session.createBytesMessage();
                msg.writeBytes(body);
                printMD5Sum(body);

                for (int i = 0; i < 2000; i++)
                {
                    msg.setJMSCorrelationID(Integer.toString(i));
                    producer.send(msg);
                }

                session.close();
                conn.close();

                System.out.println("Done!");

            }
            catch (JMSException jmse)
            {
                System.err.println("-------------------------------");
                System.err.println(jmse.getMessage());
                System.err.println(jmse.getErrorCode());
                System.err.println("-------------------------------");
            }
        }



    }

    public static void printMD5Sum(byte[] data) throws NoSuchAlgorithmException
    {
        MessageDigest m = MessageDigest.getInstance("MD5");
        m.update(data,0,data.length);
        BigInteger i = new BigInteger(1,m.digest());
        System.out.println(String.format("%1$032X", i));
    }
}