Package org.hornetq.core.config

Examples of org.hornetq.core.config.BridgeConfiguration

492
493
494
495
496
497
498
499
500
501
502
      server0.getConfiguration().setConnectorConfigurations(connectors);

      ArrayList<String> staticConnectors = new ArrayList<String>();
         staticConnectors.add(server1tc.getName());

      BridgeConfiguration bridgeConfiguration = new BridgeConfiguration("bridge1",
                                                                        queueName0,
                                                                        forwardAddress,
                                                                        null,
                                                                        SimpleTransformer.class.getName(),
                                                                        1000,
View Full Code Here
635
636
637
638
639
640
641
642
643
644
645
         server0.getConfiguration().setConnectorConfigurations(connectors);

         ArrayList<String> staticConnectors = new ArrayList<String>();
         staticConnectors.add(server1tc.getName());

         BridgeConfiguration bridgeConfiguration = new BridgeConfiguration("bridge1",
                                                                           queueName0,
                                                                           forwardAddress,
                                                                           null,
                                                                           null,
                                                                           1000,
View Full Code Here
776
777
778
779
780
781
782
783
784
785
786
         final int numMessages = 10;

         ArrayList<String> staticConnectors = new ArrayList<String>();
         staticConnectors.add(server1tc.getName());
         BridgeConfiguration bridgeConfiguration = new BridgeConfiguration("bridge1",
                                                                           queueName0,
                                                                           null, // pass a null forwarding address to use messages' original address
                                                                           null,
                                                                           null,
                                                                           1000,
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
         final String bridgeName = "bridge1";

         ArrayList<String> staticConnectors = new ArrayList<String>();
         staticConnectors.add(server1tc.getName());
         BridgeConfiguration bridgeConfiguration = new BridgeConfiguration(bridgeName,
                                                                           queueName0,
                                                                           forwardAddress,
                                                                           null,
                                                                           null,
                                                                           1000,
View Full Code Here
1733
1734
1735
1736
1737
1738
1739
1740
1741
1742
1743
1744
1745
1746
1747
1748
1749
1750
1751
1752
1753
1754
1755
1756
1757
1758
1759
1760
1761
1762
1763
1764
1765
1766
1767
1768
1769
1770
      clearIO();


      try
      {
         BridgeConfiguration config = null;
         if (useDiscoveryGroup)
         {
            config = new BridgeConfiguration(name,
                  queueName,
                  forwardingAddress,
                  filterString,
                  transformerClassName,
                  HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
                  clientFailureCheckPeriod,
                  HornetQClient.DEFAULT_CONNECTION_TTL,
                  retryInterval,
                  HornetQClient.DEFAULT_MAX_RETRY_INTERVAL,
                  retryIntervalMultiplier,
                  initialConnectAttempts,
                  reconnectAttempts,
                  HornetQDefaultConfiguration.getDefaultBridgeConnectSameNode(),
                  useDuplicateDetection,
                  confirmationWindowSize,
                  connectorNames,
                  ha,
                  user,
                  password);
         }
         else
         {
            List<String> connectors = toList(connectorNames);
            config = new BridgeConfiguration(name,
                  queueName,
                  forwardingAddress,
                  filterString,
                  transformerClassName,
                  HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
View Full Code Here
75
76
77
78
79
80
81
82
83
84
        final ServiceRegistry registry = context.getServiceRegistry(true);
        final ServiceController<?> hqService = registry.getService(MessagingServices.JBOSS_MESSAGING);
        if (hqService != null && hqService.getState() == ServiceController.State.UP) {

            final String name = PathAddress.pathAddress(operation.require(ModelDescriptionConstants.OP_ADDR)).getLastElement().getValue();
            final BridgeConfiguration bridgeConfiguration = BridgeAdd.createBridgeConfiguration(name, model);
            HornetQServer server = HornetQServer.class.cast(hqService.getValue());
            BridgeAdd.createBridge(name, bridgeConfiguration, server.getHornetQServerControl());
        }
    }
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
                        MessagingServices.JBOSS_MESSAGING, ServiceController.State.UP, hqService.getState()));
            }

            final String name = PathAddress.pathAddress(operation.require(ModelDescriptionConstants.OP_ADDR)).getLastElement().getValue();

            BridgeConfiguration bridgeConfig = createBridgeConfiguration(name, model);

            HornetQServerControl serverControl = HornetQServer.class.cast(hqService.getValue()).getHornetQServerControl();
            createBridge(name, bridgeConfig, serverControl);

        }
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
        final boolean ha = CommonAttributes.HA.validateResolvedOperation(model).asBoolean();
        final String user = CommonAttributes.USER.validateResolvedOperation(model).asString();
        final String password = CommonAttributes.PASSWORD.validateResolvedOperation(model).asString();

        if (discoveryGroupName != null) {
            return new BridgeConfiguration(name, queueName, forwardingAddress, filterString, transformerClassName,
                              retryInterval, retryIntervalMultiplier, reconnectAttempts, useDuplicateDetection,
                              confirmationWindowSize, clientFailureCheckPeriod, discoveryGroupName, ha,
                              user, password);
        } else {
            return new BridgeConfiguration(name, queueName, forwardingAddress, filterString, transformerClassName,
                              retryInterval, retryIntervalMultiplier, reconnectAttempts, useDuplicateDetection,
                              confirmationWindowSize, clientFailureCheckPeriod, staticConnectors, ha,
                              user, password);
        }
    }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
         ArrayList<String> staticConnectors = new ArrayList<String>();
         staticConnectors.add(server1tc.getName());

         final String bridgeName = "bridge1";

         BridgeConfiguration bridgeConfiguration = new BridgeConfiguration(bridgeName,
                                                                           queueName0,
                                                                           forwardAddress,
                                                                           null,
                                                                           null,
                                                                           HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
View Full Code Here
273
274
275
276
277
278
279
280
281
282
283
      ArrayList<String> staticConnectors = new ArrayList<String>();
         staticConnectors.add(server1tc.getName());

      final String bridgeName = "bridge1";

      BridgeConfiguration bridgeConfiguration = new BridgeConfiguration(bridgeName,
                                                                        queueName0,
                                                                        forwardAddress,
                                                                        null,
                                                                        null,
                                                                        HornetQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
View Full Code Here
TOP

Related Classes of org.hornetq.core.config.BridgeConfiguration

  • org.hornetq.core.deployers.impl.FileConfigurationParser
  • org.hornetq.core.management.impl.HornetQServerControlImpl
  • org.hornetq.tests.integration.cluster.bridge.BridgeFailoverTest
  • org.hornetq.tests.integration.cluster.bridge.BridgeReconnectTest
  • org.hornetq.tests.integration.cluster.bridge.BridgeStartTest
  • org.hornetq.tests.integration.cluster.bridge.BridgeTest
  • org.hornetq.tests.integration.cluster.bridge.BridgeWithDiscoveryGroupStartTest
  • org.hornetq.tests.integration.cluster.bridge.BridgeWithPagingTest
  • org.hornetq.tests.integration.management.BridgeControlTest
  • org.hornetq.tests.integration.management.BridgeControlUsingCoreTest
    • Copyright © 2018 www.massapicom. 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.