Runner[] runners = new Runner[] { new Transactional2PCSender("prod1", sessSend, prod, NUM_NON_PERSISTENT_MESSAGES, 100, 33), new Receiver(sessReceive, cons, NUM_NON_PERSISTENT_MESSAGES, true) };
Runner[] runners = new Runner[] { new Transactional2PCSender("prod1", sessSend, prod, NUM_PERSISTENT_MESSAGES, 100, 33), new Receiver(sessReceive, cons, NUM_PERSISTENT_MESSAGES, true) };
   public void test_Simple_XP_LD() throws Exception   {      Connection conn1 = cf.createConnection();      Connection conn2 = cf.createConnection();      conn2.start();            XASession sessSend = ((XAConnection)conn1).createXASession();      Session sessReceive = conn2.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);            MessageConsumer cons = sessReceive.createConsumer(queue1);      MessageProducer prod = sessSend.createProducer(queue1);      prod.setDeliveryMode(DeliveryMode.PERSISTENT);            Runner[] runners = new Runner[] { new Transactional2PCSender("prod1", sessSend, prod, NUM_NON_PERSISTENT_MESSAGES, 100, 33),            new Receiver(sessReceive, cons, NUM_NON_PERSISTENT_MESSAGES, true) };            runRunners(runners);            conn1.close(); conn2.close();         }