Examples of ProtocolData

org.jboss.ha.core.channelfactory.ProtocolData
Data holder for protocol @author Filip Hanik (filip@filip.net) @author Bela Ban @version $Id: ProtocolData.java,v 1.10 2009/05/13 05:35:45 belaban Exp $

org.jgroups.conf.ProtocolData

Examples of org.jboss.ha.core.channelfactory.ProtocolData

      assertNotNull(unshared1);
      ProtocolData[] origConfig = unshared1.getConfiguration();
      assertNotNull(origConfig);
      // Copy it off so we know it's unchanged for later assertion comparisons
      origConfig = origConfig.clone();
      ProtocolData origTransport = origConfig[0];
      assertNotNull(origTransport);
      ProtocolParameter[] origParams = origTransport.getParametersAsArray();
      ProtocolParameter[] newParams = origParams.clone();      
      ProtocolData newTransport = new ProtocolData(origTransport.getProtocolName(), origTransport.getClassName(), newParams);
      ProtocolParameter overrideParam = new ProtocolParameter("max_bundle_size", "50000");
      newTransport.override(new ProtocolParameter[]{overrideParam});
      ProtocolData[] newConfig = origConfig.clone();
      newConfig[0] = newTransport;
      
      ProtocolStackConfigInfo updated = new ProtocolStackConfigInfo(unshared1.getName(), unshared1.getDescription(), newConfig);

View Full Code Here

Examples of org.jboss.ha.core.channelfactory.ProtocolData

         {
            CompositeValue paramValue = (CompositeValue) paramsValue.get(paramName);
            String paramVal = (String) ((SimpleValue) paramValue.get("value")).getValue();
            protParams.add(new ProtocolParameter(paramName, paramVal));
         }
         protocolData[i] = new ProtocolData(protName, protClass, protParams);
      }
      return protocolData;
   }

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

   
   private Map<String, String> getTransportProperties(ProtocolStackConfigurator config)
   {
      Map<String, String> tpProps = null;
      ProtocolData[] protocols= ProtocolStackUtil.getProtocolData(config);
      ProtocolData transport=protocols[0];
      @SuppressWarnings("unchecked")
      Map<String,ProtocolParameter> tmp=transport.getParameters();
      tpProps = new HashMap<String,String>();
      for(Map.Entry<String,ProtocolParameter> entry: tmp.entrySet())
      {
          tpProps.put(entry.getKey(), entry.getValue().getValue());
      }

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

   {
      ProtocolStackConfigurator result = null;
      try
      {
         ProtocolData[] protocols=orig.getProtocolStack();
         ProtocolData transport=protocols[0];
         ProtocolParameter singletonParam = new ProtocolParameter(Global.SINGLETON_NAME, singletonName);
         transport.override(new ProtocolParameter[]{ singletonParam});
         result = orig;
      }
      catch (UnsupportedOperationException uoe)
      {
         // JGroups version hasn't implemented ProtocolStackConfigurator.getProtocolStack()

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

            else
            {
               params = new ProtocolParameter[0];
            }
            
            result[i] = new ProtocolData(name, name, params);
         }
      }
      
      return result == null ? new ProtocolData[0] : result;
   }

View Full Code Here

Examples of org.jgroups.conf.ProtocolData




    private static JChannel createSharedChannel(String singleton_name) throws ChannelException {
        ProtocolStackConfigurator config=ConfiguratorFactory.getStackConfigurator(CHANNEL_CONFIG);
        ProtocolData[] protocols=config.getProtocolStack();
        ProtocolData transport=protocols[0];
        transport.getParameters().put(Global.SINGLETON_NAME, new ProtocolParameter(Global.SINGLETON_NAME, singleton_name));
        return new JChannel(config);
    }

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

   
   private Map<String, String> getTransportProperties(ProtocolStackConfigurator config)
   {
      Map<String, String> tpProps = null;
      ProtocolData[] protocols= ProtocolStackUtil.getProtocolData(config);
      ProtocolData transport=protocols[0];
      @SuppressWarnings("unchecked")
      Map<String,ProtocolParameter> tmp=transport.getParameters();
      tpProps = new HashMap<String,String>();
      for(Map.Entry<String,ProtocolParameter> entry: tmp.entrySet())
      {
          tpProps.put(entry.getKey(), entry.getValue().getValue());
      }

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

   {
      ProtocolStackConfigurator result = null;
      try
      {
         ProtocolData[] protocols=orig.getProtocolStack();
         ProtocolData transport=protocols[0];
         ProtocolParameter singletonParam = new ProtocolParameter(Global.SINGLETON_NAME, singletonName);
         transport.override(new ProtocolParameter[]{ singletonParam});
         result = orig;
      }
      catch (UnsupportedOperationException uoe)
      {
         // JGroups version hasn't implemented ProtocolStackConfigurator.getProtocolStack()

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

            else
            {
               params = new ProtocolParameter[0];
            }
            
            result[i] = new ProtocolData(name, null, name, params);
         }
      }
      
      return result == null ? new ProtocolData[0] : result;
   }

View Full Code Here

Examples of org.jgroups.conf.ProtocolData

   
   private Map<String, String> getTransportProperties(ProtocolStackConfigurator config)
   {
      Map<String, String> tpProps = null;
      ProtocolData[] protocols= ProtocolStackUtil.getProtocolData(config);
      ProtocolData transport=protocols[0];
      @SuppressWarnings("unchecked")
      Map<String,ProtocolParameter> tmp=transport.getParameters();
      tpProps = new HashMap<String,String>();
      for(Map.Entry<String,ProtocolParameter> entry: tmp.entrySet())
      {
          tpProps.put(entry.getKey(), entry.getValue().getValue());
      }

View Full Code Here

0 1

TOP

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.