Package org.hornetq.jms.bridge.impl

Examples of org.hornetq.jms.bridge.impl.JMSBridgeImpl.start()

2104
2105
2106
2107
2108
2109
2110
2111
2112
2113
2114
                                    null,
                                    null,
                                    false);
         bridge.setTransactionManager(newTransactionManager());

         bridge.start();

         sendMessages(cf0, sourceQueue, 0, NUM_MESSAGES / 2, persistent, false);

         checkEmpty(targetQueue, 1);
View Full Code Here
2184
2185
2186
2187
2188
2189
2190
2191
2192
2193
2194
                                    null,
                                    null,
                                    false);
         bridge.setTransactionManager(newTransactionManager());

         bridge.start();

         final int NUM_MESSAGES = 10;

         // Send some message
View Full Code Here
2244
2245
2246
2247
2248
2249
2250
2251
2252
2253
2254
                                    null,
                                    null,
                                    false);
         bridge.setTransactionManager(newTransactionManager());

         bridge.start();

         final int NUM_MESSAGES = 10;

         // Send some message
View Full Code Here
2296
2297
2298
2299
2300
2301
2302
2303
2304
2305
2306
                                    null,
                                    null,
                                    false);
         bridge.setTransactionManagerLocatorClass(this.getClass().getName());
         bridge.setTransactionManagerLocatorMethod("getNewTm");
         bridge.start();
      }
      finally
      {
         if (bridge != null)
         {
View Full Code Here
258
259
260
261
262
263
264
265
266
267
268
      bridge.setMaxBatchTime(-1);
      bridge.setTransactionManager(tm);
      bridge.setQualityOfServiceMode(QualityOfServiceMode.AT_MOST_ONCE);

      Assert.assertFalse(bridge.isStarted());
      bridge.start();

      Thread.sleep(500);
      Assert.assertTrue(bridge.isStarted());
      Assert.assertFalse(bridge.isFailed());
View Full Code Here
297
298
299
300
301
302
303
304
305
306
307
      bridge.setMaxBatchTime(maxBatchTime);
      bridge.setTransactionManager(tm);
      bridge.setQualityOfServiceMode(QualityOfServiceMode.AT_MOST_ONCE);

      Assert.assertFalse(bridge.isStarted());
      bridge.start();
      Assert.assertTrue(bridge.isStarted());

      Connection targetConn = JMSBridgeImplTest.createConnectionFactory().createConnection();
      Session targetSess = targetConn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageConsumer consumer = targetSess.createConsumer(targetDF.createDestination());
View Full Code Here
357
358
359
360
361
362
363
364
365
366
367
      bridge.setMaxBatchTime(-1);
      bridge.setTransactionManager(tm);
      bridge.setQualityOfServiceMode(QualityOfServiceMode.AT_MOST_ONCE);

      Assert.assertFalse(bridge.isStarted());
      bridge.start();
      Assert.assertTrue(bridge.isStarted());

      Connection targetConn = JMSBridgeImplTest.createConnectionFactory().createConnection();
      Session targetSess = targetConn.createSession(false, Session.AUTO_ACKNOWLEDGE);
      MessageConsumer consumer = targetSess.createConsumer(targetDF.createDestination());
View Full Code Here
446
447
448
449
450
451
452
453
454
455
456
      bridge.setMaxBatchTime(-1);
      bridge.setTransactionManager(tm);
      bridge.setQualityOfServiceMode(QualityOfServiceMode.AT_MOST_ONCE);

      Assert.assertFalse(bridge.isStarted());
      bridge.start();
      Assert.assertTrue(bridge.isStarted());

      sourceConn.get().getExceptionListener().onException(new JMSException("exception on the source"));
      Thread.sleep(4 * bridge.getFailureRetryInterval());
      // reconnection must have succeeded
View Full Code Here
506
507
508
509
510
511
512
513
514
515
516
      bridge.setMaxBatchTime(-1);
      bridge.setTransactionManager(tm);
      bridge.setQualityOfServiceMode(QualityOfServiceMode.AT_MOST_ONCE);

      Assert.assertFalse(bridge.isStarted());
      bridge.start();
      Assert.assertTrue(bridge.isStarted());

      sourceConn.get().getExceptionListener().onException(new JMSException("exception on the source"));
      Thread.sleep(4 * bridge.getFailureRetryInterval());
      // reconnection must have failed
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
                                               false);
      bridge.setTransactionManager(newTransactionManager());

      try
      {
         bridge.start();
         Assert.assertFalse(bridge.isStarted());
         Assert.assertTrue(bridge.isFailed());

         // Restart the server
         jmsServer1.start();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.