import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
private String getParam (Map params, String toGet, boolean required, String def) throws DataProviderException {
    String res = (String) params.get(toGet);
    if (res == null) {
        if (required) {
            throw new DataProviderException(toGet + noParam);
        } else {
            if (logger != null) {
                logger.warn(toGet + useDefault);
            }
            res = def;
        }
    }
    if (logger != null) {
        logger.debug(toGet+ ": " + res);
    }
    return res;
}
 

import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
public void init(Map params, File configDir) throws DataProviderException {
    
    // Logging configuration for the demo is carried out in the init
    // method of Metadata Adapter. In order to be sure that this method 
    // is executed after log configuration was completed, this parameter 
    // must be present in the Adapter Set configuration (adapters.xml):
    // <metadata_adapter_initialised_first>Y</metadata_adapter_initialised_first>
    logger = Logger.getLogger("LS_demos_Logger.Messenger");

    // Read the Adapter Set name, which is supplied by the Server as a parameter
    String adapterSetId = (String) params.get("adapters_conf.id");

    // Put a reference to this instance on a static map
    // to be read by the Metadata Adapter
    feedMap.put(adapterSetId, this);

    // Adapter ready
    logger.info("IMDataAdapter ready");

}
 

import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
public void init(Map params, File configDir) throws DataProviderException {

        // Logging configuration for the demo is carried out in the init
        // method of Metadata Adapter. In order to be sure that this method 
        // is executed after log configuration was completed, this parameter 
        // must be present in the Adapter Set configuration (adapters.xml):
        // <metadata_adapter_initialised_first>Y</metadata_adapter_initialised_first>
        logger = Logger.getLogger("LS_demos_Logger.RoundTrip");

        // Read the Adapter Set name, which is supplied by the Server as a parameter
        String adapterSetId = (String) params.get("adapters_conf.id");

        // Put a reference to this instance on a static map
        // to be read by the Metadata Adapter
        feedMap.put(adapterSetId, this);

        // Adapter ready
        logger.info("RounTripDataAdapter ready");

    }
 

import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
@Override
public void init(Map params, File configDir) throws DataProviderException {
    String logConfig = (String) params.get("log_config");
    if (logConfig != null) {
        File logConfigFile = new File(configDir, logConfig);
        String logRefresh = (String) params.get("log_config_refresh_seconds");
        if (logRefresh != null) {
            DOMConfigurator.configureAndWatch(logConfigFile.getAbsolutePath(), Integer.parseInt(logRefresh) * 1000);
        } else {
            DOMConfigurator.configure(logConfigFile.getAbsolutePath());
        }
    } //else the bridge to logback is expected
    
    logger = Logger.getLogger(Constants.LOGGER_CAT);
    
    logger.info("Adapter Logger start.");
    
    // Read the Adapter Set name, which is supplied by the Server as a parameter
    String adapterSetId = (String) params.get("adapters_conf.id");
    
    // Put a reference to this instance on a static map
    // to be read by the Metadata Adapter
    feedMap.put(adapterSetId, this);
    
    
    logger.info("DartDataAdapter ready");
    
}
 

import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
/**
 * Called by Lightstreamer Kernel on start.
 */
public void init(Map params, File configDir) throws DataProviderException {
    //load log configuration
    String logConfig = (String) params.get("log_config");
    if (logConfig != null) {
        File logConfigFile = new File(configDir, logConfig);
        String logRefresh = (String) params.get("log_config_refresh_seconds");
        if (logRefresh != null) {
            DOMConfigurator.configureAndWatch(logConfigFile.getAbsolutePath(), Integer.parseInt(logRefresh) * 1000);
        } else {
            DOMConfigurator.configure(logConfigFile.getAbsolutePath());
        }
    }
    //get the logger
    logger = Logger.getLogger("LS_demos_Logger.StockQuotesJMS");

    //load JMS connections parameters
    String providerURL = getParam(params,"jmsUrl",true,null);
    String initialContextFactory = getParam(params,"initialContextFactory",true,null);
    String topicConnectionFactory = getParam(params,"topicConnectionFactory",true,null);
    String queueConnectionFactory = getParam(params,"queueConnectionFactory",true,null);
    String topic = getParam(params,"topicName",true,null);
    String queue = getParam(params,"queueName",true,null);
    //the size of the message pool
    this.msgPoolSize = getParam(params,"msgPoolSize",false,15);
    //in case of disconnection/failed_connection from/to JMS this is
    //the pause between each reconnection attempt
    this.recoveryPause = getParam(params,"recoveryPauseMillis",false,2000);

    logger.debug("Configuration read.");

    //create the JMS handler. The object will handle the instantiation of JMS-related objects
    jmsHandler = new JMSHandler(logger,initialContextFactory, providerURL,queueConnectionFactory, queue, topicConnectionFactory, topic);
    //the message listener that will receive JMS messages will be the StockQuotesJMSDataAdapter instance (this)
    jmsHandler.setListener(this);

    //this thread keeps on trying to connect to JMS until succedes. When connected
    //calls the onConnection method
    new ConnectionLoopTSQS(jmsHandler, recoveryPause, logger).start();

    logger.info("StockQuotesJMSDataAdapter ready.");
}
 

import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public void init(Map params, File configDir) throws DataProviderException {}
 

import com.lightstreamer.interfaces.data.DataProviderException; //导入依赖的package包/类
public void init(Map params, File configDir) throws DataProviderException {
}