public void testDeath2() throws Exception
    {
        AMQConnection con = (AMQConnection) getConnection();
        TopicSession session1 = con.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
        AMQTopic topic = new AMQTopic(con.getDefaultTopicExchangeName(), "death");
        TopicPublisher publisher = session1.createPublisher(topic);

        MessageListener messageListener = new MessageListener()
        {
            public void onMessage(Message message)
            {
            }
        };

        List<TopicSubscriber> listenerList = new ArrayList<TopicSubscriber>();

        TopicSubscriber listener = session1.createSubscriber(topic);
        listener.setMessageListener(messageListener);
        listenerList.add(listener);


        con.start();

        for(int i=0; i < 10000 ; i++)
        {
            BytesMessage outmsg = session1.createBytesMessage();
            final byte[] bytes = new byte[1024];
            outmsg.writeBytes(bytes);
            publisher.send(outmsg);

            System.out.println("Sent " + i + "messages") ;

            listener = session1.createSubscriber(topic);
            listener.setMessageListener(messageListener);
            listenerList.add(listener);

        }
    } 

Executing above the client eventually times out on sync; broker appears not to
respond.