Runner[] runners = new Runner[] { new Transactional2PCSender("prod1", sessSend, prod, NUM_PERSISTENT_MESSAGES, 100, 33), new Transactional2PCReceiver(sessReceive, cons, NUM_PERSISTENT_MESSAGES, 100, 67, true) };
Runner[] runners = new Runner[] { new Transactional2PCSender("prod1", sessSend, prod, NUM_NON_PERSISTENT_MESSAGES, 100, 33), new Transactional2PCReceiver(sessReceive, cons, NUM_NON_PERSISTENT_MESSAGES, 100, 67, true) };
   public void test_Simple_XNP_LX() throws Exception   {      Connection conn = cf.createConnection();      conn.start();            XASession sessSend = ((XAConnection)conn).createXASession();      XASession sessReceive = ((XAConnection)conn).createXASession();            MessageConsumer cons = sessReceive.createConsumer(topic1);      MessageProducer prod = sessSend.createProducer(topic1);      prod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);            Runner[] runners = new Runner[] { new Transactional2PCSender("prod1", sessSend, prod, NUM_PERSISTENT_MESSAGES, 100, 33),                                        new Transactional2PCReceiver(sessReceive, cons, NUM_PERSISTENT_MESSAGES, 100, 67, true) };      runRunners(runners);      conn.close();         }