Package org.jgroups.conf

Examples of org.jgroups.conf.ProtocolStackConfigurator
74
75
76
77
78
79
80
81
82
83
84
85
     * {@inheritDoc}
     * @see org.jboss.msc.service.Service#start(org.jboss.msc.service.StartContext)
     */
    @Override
    public void start(final StartContext context) throws StartException {
        ProtocolStackConfigurator configurator = load(ProtocolDefaultsService.this.resource);
        Defaults defaults = new Defaults();
        for (org.jgroups.conf.ProtocolConfiguration config: configurator.getProtocolStack()) {
            defaults.add(config.getProtocolName(), config.getProperties());
        }
        ProtocolDefaultsService.this.defaults = defaults;
    }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
55
56
  @Test
  public void should_create_jchannel_using_provided_configurator_and_cluster_name() throws Exception {
    JGroupsChannelFactoryBean factoryBean = new JGroupsChannelFactoryBean();

    ProtocolStackConfigurator protocolStackConfigurator = mock(ProtocolStackConfigurator.class);
    List<ProtocolConfiguration> protocols = asList(new ProtocolConfiguration("UDP"));
    when(protocolStackConfigurator.getProtocolStack()).thenReturn(protocols);


    factoryBean.setProtocolStackConfigurator(protocolStackConfigurator);
    factoryBean.setClusterName("cluster");
    factoryBean.afterPropertiesSet();
View Full Code Here
39
40
41
42
43
44
45
46
47
  public void should_load_configuration_from_xml_file() throws Exception {
    XmlConfiguratorFactoryBean factoryBean = new XmlConfiguratorFactoryBean();
    factoryBean.setResource(new ClassPathResource("/udp.xml"));
    factoryBean.afterPropertiesSet();

    ProtocolStackConfigurator configurator = factoryBean.getObject();

    assertThat(configurator.getProtocolStack()).isNotEmpty();
  }
View Full Code Here
53
54
55
56
57
58
59
60
    expectedException.expect(IllegalArgumentException.class);
    expectedException.expectMessage(is("no XML resource with JGroups configuration"));

    factoryBean.afterPropertiesSet();

    @SuppressWarnings("unused")
    ProtocolStackConfigurator stackConfigurator = factoryBean.getObject();
  }
View Full Code Here
264
265
266
267
268
269
270
271
272
273
274
     */
    public JChannel(Object properties) throws ChannelException {
        if (properties == null)
            properties = DEFAULT_PROTOCOL_STACK;

        ProtocolStackConfigurator c=null;

        try {
            c=ConfiguratorFactory.getStackConfigurator(properties);
        }
        catch(Exception x) {
View Full Code Here
261
262
263
264
265
266
267
268
269
270
271
     */
    public JChannel(Object properties) throws ChannelException {
        if (properties == null)
            properties = DEFAULT_PROTOCOL_STACK;

        ProtocolStackConfigurator c;

        try {
            c=ConfiguratorFactory.getStackConfigurator(properties);
        }
        catch(Exception x) {
View Full Code Here
261
262
263
264
265
266
267
268
269
270
271
     */
    public JChannel(Object properties) throws ChannelException {
        if (properties == null)
            properties = DEFAULT_PROTOCOL_STACK;

        ProtocolStackConfigurator c;

        try {
            c=ConfiguratorFactory.getStackConfigurator(properties);
        }
        catch(Exception x) {
View Full Code Here
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
      checkStarted();

      if (properties == null)
         properties = JChannel.DEFAULT_PROTOCOL_STACK;

      ProtocolStackConfigurator config = null;

      try
      {
         ProtocolStackConfigurator c = ConfiguratorFactory.getStackConfigurator(properties);
         config = c;
      }
      catch (Exception x)
      {
         throw new ChannelException("unable to load protocol stack", x);
View Full Code Here
1413
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
   }
 
   private ProtocolStackConfigurator addSingletonName(ProtocolStackConfigurator orig, String singletonName)
      throws ChannelException
   {
      ProtocolStackConfigurator result = null;
      try
      {
         ProtocolData[] protocols=orig.getProtocolStack();
         ProtocolData transport=protocols[0];
         ProtocolParameter singletonParam = new ProtocolParameter(Global.SINGLETON_NAME, singletonName);
View Full Code Here
265
266
267
268
269
270
271
272
273
274
275
     */
    public JChannel(Object properties) throws ChannelException {
        if (properties == null)
            properties = DEFAULT_PROTOCOL_STACK;

        ProtocolStackConfigurator c=null;

        try {
            c=ConfiguratorFactory.getStackConfigurator(properties);
        }
        catch(Exception x) {
View Full Code Here
TOP

Related Classes of org.jgroups.conf.ProtocolStackConfigurator

  • org.jboss.as.clustering.jgroups.subsystem.ProtocolDefaultsService
  • org.jboss.as.clustering.jgroups.subsystem.ProtocolStackAdd
  • org.jboss.ha.core.channelfactory.JChannelFactory
  • org.jboss.ha.framework.server.JChannelFactory
  • org.jgroups.demos.PubSub
  • org.jgroups.JChannel
  • org.jgroups.tests.SharedTransportTest
  • org.jgroups.tests.SpeedTest
  • org.modeshape.jcr.clustering.ClusteringService$StandaloneClusteringService
  • org.springframework.integration.jgroups.JGroupsChannelFactoryBeanTest
    • 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.