10741075107610771078107910801081108210831084
-1, null, null, false); bridge.setTransactionManager(mgr); bridge.start(); sendMessages(cf0, sourceTopic, 0, NUM_MESSAGES, false, largeMessage); checkAllMessageReceivedInOrder(cf1, targetQueue, 0, NUM_MESSAGES, largeMessage); }
11491150115111521153115411551156115711581159
null, null, false); bridge.setTransactionManager(newTransactionManager()); bridge.start(); sendMessages(cf0, sourceTopic, 0, NUM_MESSAGES, false, largeMessage); checkAllMessageReceivedInOrder(cf1, targetQueue, 0, NUM_MESSAGES, largeMessage); }
12011202120312041205120612071208120912101211
"subTest", "clientid123", false); bridge.setTransactionManager(newTransactionManager()); bridge.start(); sendMessages(cf0, sourceTopic, 0, NUM_MESSAGES, true, largeMessage); checkAllMessageReceivedInOrder(cf1, targetQueue, 0, NUM_MESSAGES, largeMessage); }
12641265126612671268126912701271127212731274
null, null, on); bridge.setTransactionManager(newTransactionManager()); bridge.start(); connSource = cf0.createConnection(); connTarget = cf1.createConnection();
14681469147014711472147314741475147614771478
null, null, messageIDInHeader); bridge.setTransactionManager(newTransactionManager()); bridge.start(); connSource = cf0.createConnection(); connTarget = cf1.createConnection();
16421643164416451646164716481649165016511652
null, null, false); bridge.setTransactionManager(newTransactionManager()); bridge.start(); connSource = cf0.createConnection(); connTarget = cf1.createConnection();
17491750175117521753175417551756175717581759
null, null, false); bridge.setTransactionManager(newTransactionManager()); bridge.start(); connSource = cf0.createConnection(); Session sessSend = connSource.createSession(false, Session.AUTO_ACKNOWLEDGE);
18431844184518461847184818491850185118521853
19361937193819391940194119421943194419451946
20272028202920302031203220332034203520362037
null, null, false); bridge.setTransactionManager(newTransactionManager()); bridge.start(); // Send half the messges sendMessages(cf0, sourceQueue, 0, NUM_MESSAGES / 2, persistent, false);