93949596979899100101102103
null, null, null, null, null, 1000, -1, Bridge.QOS_ONCE_AND_ONLY_ONCE, NUM_MESSAGES, -1, null, null, false); bridge.start(); //Poison server 1 so it crashes on commit of dest but after prepare //This means the transaction branch on source will get commmitted //but the branch on dest won't be - it will remain prepared
103104105106107108109110111112113
10, -1, null, null, false); try { bridge.start(); assertFalse(bridge.isStarted()); assertTrue(bridge.isFailed()); ServerManagement.start(1, "all", false); ServerManagement.deployQueue("targetQueue", 1);
148149150151152153154155156157158
null, null, null, null, null, 1000, -1, qosMode, 10, -1, null, null, false); bridge.start(); final int NUM_MESSAGES = 10; //Send some messages
228229230231232233234235236237238
null, null, null, null, null, 1000, -1, Bridge.QOS_ONCE_AND_ONLY_ONCE, 10, 5000, null, null, false); bridge.start(); final int NUM_MESSAGES = 10; //Send some messages this.sendMessages(cf0, sourceQueue, 0, NUM_MESSAGES / 2, persistent);
521522523524525526527528529530531
null, null, null, null, selector, 5000, 10, Bridge.QOS_AT_MOST_ONCE, 1, -1, null, null, false); bridge.start(); connSource = cf0.createConnection(); Session sessSend = connSource.createSession(false, Session.AUTO_ACKNOWLEDGE);
615616617618619620621622623624625
null, null, null, null, null, 5000, 10, Bridge.QOS_AT_MOST_ONCE, 1, -1, null, null, false); bridge.start(); this.sendMessages(cf0, sourceTopic, 0, NUM_MESSAGES, false); this.checkAllMessageReceivedInOrder(cf1, targetQueue, 0, NUM_MESSAGES); }
667668669670671672673674675676677
null, null, null, null, null, 5000, 10, Bridge.QOS_AT_MOST_ONCE, 1, -1, null, null, false); bridge.start(); sendMessages(cf0, sourceTopic, 0, NUM_MESSAGES, false); checkAllMessageReceivedInOrder(cf1, targetQueue, 0, NUM_MESSAGES); }
696697698699700701702703704705706
null, null, null, null, null, 5000, 10, Bridge.QOS_AT_MOST_ONCE, 1, -1, "subTest", "clientid123", false); bridge.start(); sendMessages(cf0, sourceTopic, 0, NUM_MESSAGES, true); checkAllMessageReceivedInOrder(cf1, targetQueue, 0, NUM_MESSAGES); }
746747748749750751752753754755756
null, null, null, null, null, 5000, 10, Bridge.QOS_AT_MOST_ONCE, 1, -1, null, null, on); bridge.start(); connSource = cf0.createConnection(); connTarget = cf1.createConnection();
917918919920921922923924925926927
null, null, null, null, null, 5000, 10, Bridge.QOS_AT_MOST_ONCE, 1, -1, null, null, messageIDInHeader); bridge.start(); connSource = cf0.createConnection(); connTarget = cf1.createConnection();