Jim

package com.myorg.pelican;

import org.apache.log4j.Logger;
import org.apache.thrift.TException;
import org.hornetq.api.core.TransportConfiguration;
import org.hornetq.api.jms.HornetQJMSClient;
import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory;
import org.hornetq.integration.transports.netty.TransportConstants;
import org.hornetq.jms.client.HornetQConnectionFactory;

import javax.jms.*;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Map;


public class PelicanRunner {

    final static Logger logger = Logger.getLogger(PelicanRunner.class);

    public static void main(String[] args) {

        logger.info("Starting up Pelican Test Code");

        testHornetJMS();

    }

    private static void testHornetJMS() {

        Map<String, Object> connectionParams = new HashMap<String, Object>();
        connectionParams.put(TransportConstants.PORT_PROP_NAME, 5455);
        connectionParams.put(TransportConstants.HOST_PROP_NAME, "cache09");
        TransportConfiguration tc = new
                TransportConfiguration(NettyConnectorFactory.class.getName(),
                connectionParams);

        HornetQConnectionFactory cf = HornetQJMSClient.createConnectionFactory(tc);

        //This stuff happens on a per thread basis
        Connection connection = null;
        Session session = null;
        MessageProducer producer = null;
        try {
            connection = cf.createConnection();
            connection.start();
            session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
            Destination destination = session.createQueue("jimTest2");
            producer = session.createProducer(destination);


            System.out.println(now());
            for (int i = 0; i < 50000; i++) {
                TextMessage message = session.createTextMessage("THIS IS A TEST MSG");
                producer.send(message);
                if(i % 10000 == 0) {
                    System.out.println(i+ " messages inserted");
                }
            }
            System.out.println("COMPLETE");
            System.out.println(now());

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (producer != null) {
                try {
                    producer.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if (session != null) {
                try {
                    session.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }


    }

    public static String now() {
        Calendar cal = Calendar.getInstance();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return sdf.format(cal.getTime());

    }

}