Package org.hornetq.core.server.cluster

Examples of org.hornetq.core.server.cluster.Bridge.stop()

522
523
524
525
526
527
528
529
530
531
532
      synchronized (this)
      {
         bridge = bridges.remove(name);
         if (bridge != null)
         {
            bridge.stop();
            managementService.unregisterBridge(name);
         }
      }

      bridge.flushExecutor();
View Full Code Here
524
525
526
527
528
529
530
531
532
533
534
      synchronized (this)
      {
         bridge = bridges.remove(name);
         if (bridge != null)
         {
            bridge.stop();
            managementService.unregisterBridge(name);
         }
      }

      bridge.flushExecutor();
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
      Assert.assertNull(consumer1.receiveImmediate());

      Bridge bridge = server0.getClusterManager().getBridges().get(bridgeName);

      bridge.stop();

      for (int i = 0; i < numMessages; i++)
      {
         ClientMessage message = session0.createMessage(false);
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
      Assert.assertNull(consumer1.receiveImmediate());

      Bridge bridge = server0.getClusterManager().getBridges().get(bridgeName);

      bridge.stop();

      for (int i = 0; i < numMessages; i++)
      {
         ClientMessage message = session0.createMessage(false);
View Full Code Here
662
663
664
665
666
667
668
669
670
671
672
      Bridge bridge = server0.getClusterManager().getBridges().get(bridgeName);

      BridgeStartTest.log.info("stopping bridge manually");

      bridge.stop();

      for (int i = numMessages; i < numMessages * 2; i++)
      {
         ClientMessage message = session0.createMessage(false);

View Full Code Here
695
696
697
698
699
700
701
702
703
704
705
         message.acknowledge();
      }

      Assert.assertNull(consumer1.receiveImmediate());

      bridge.stop();

      for (int i = 0; i < numMessages; i++)
      {
         ClientMessage message = session0.createMessage(false);
View Full Code Here
714
715
716
717
718
719
720
721
722
723
724
   public synchronized void destroyBridge(final String name) throws Exception
   {
      Bridge bridge = bridges.remove(name);
      if (bridge != null)
      {
         bridge.stop();
         managementService.unregisterBridge(name);
      }
   }

   private synchronized void deployClusterConnection(final ClusterConnectionConfiguration config) throws Exception
View Full Code Here
543
544
545
546
547
548
549
550
551
552
553
      synchronized (this)
      {
         bridge = bridges.remove(name);
         if (bridge != null)
         {
            bridge.stop();
            managementService.unregisterBridge(name);
         }
      }

      if (bridge!= null)
View Full Code Here
184
185
186
187
188
189
190
191
192
193
194
         Assert.assertNull(consumer1.receiveImmediate());

         Bridge bridge = server0.getClusterManager().getBridges().get(bridgeName);

         bridge.stop();
        
         bridge.flushExecutor();

         for (int i = 0; i < numMessages; i++)
         {
View Full Code Here
734
735
736
737
738
739
740
741
742
743
744
         Bridge bridge = server0.getClusterManager().getBridges().get(bridgeName);

         BridgeStartTest.log.info("stopping bridge manually");

         bridge.stop();
        
         bridge.flushExecutor();

         for (int i = numMessages; i < numMessages * 2; i++)
         {
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.