<commit_before>package org.renci.databridge.engines.network;
import  org.renci.databridge.util.*;
import  org.renci.databridge.message.*;
import java.util.logging.Logger;
import java.util.logging.Level;
import java.io.*;
import java.util.Properties;

/**
 * This is the main module for the DataBridge network engine.  This is a standalone server which
 * waits on a queue connected to the header exchange.  For each incoming message, the server 
 * looks at the message and, if needed, will fork a thread to handle the message.
 *
 */
public class NetworkEngine {

    protected static Logger logger = Logger.getLogger ("org.renci.databridge.engines.network");
    public static void main(String[] args ) {
        String propFileName = null;

        if (args.length > 0) {
            propFileName = args[0];
        } else {
            propFileName = new String("network.conf");
        }    
        try {
            Properties props= new Properties();
            props.load(new FileInputStream(propFileName));
            props.setProperty("org.renci.databridge.primaryQueue",
                              props.getProperty("org.renci.databridge.networkEngine.primaryQueue"));
            System.out.println("org.renci.databridge.primaryQueue set to: " + props.getProperty("org.renci.databridge.primaryQueue"));
            NetworkEngineMessageListener aml = 
                new NetworkEngineMessageListener (props, new NetworkEngineMessage(), 
                                                  new NetworkEngineMessageHandler(), logger);
            aml.start ();

            // Start a second thread to listen for actionable messages.
            // We need to reset the org.renci.databridge.primaryQueue property. This is the queue
            // this listener will listen to.
            props.setProperty("org.renci.databridge.primaryQueue",
                              props.getProperty("org.renci.databridge.networkEngine.ingestQueue"));
            System.out.println("org.renci.databridge.primaryQueue set to: " + props.getProperty("org.renci.databridge.primaryQueue"));

            NetworkEngineMessageListener networkListener = 
                new NetworkEngineMessageListener (props, new NetworkListenerMessage(), 
                                                  new NetworkEngineMessageHandler(), logger);
            networkListener.start ();
            networkListener.join (); // keeps main thread from exiting 
            aml.join (); // keeps main thread from exiting 
        } catch (Exception ex) {
            System.out.println(ex.toString());
            System.exit(1);
        }

    }
}<commit_msg>Replace the System.out.println calls with calls to the logger.<commit_after>package org.renci.databridge.engines.network;
import  org.renci.databridge.util.*;
import  org.renci.databridge.message.*;
import java.util.logging.Logger;
import java.util.logging.Level;
import java.io.*;
import java.util.Properties;

/**
 * This is the main module for the DataBridge network engine.  This is a standalone server which
 * waits on a queue connected to the header exchange.  For each incoming message, the server 
 * looks at the message and, if needed, will fork a thread to handle the message.
 *
 */
public class NetworkEngine {

    protected static Logger logger = Logger.getLogger ("org.renci.databridge.engines.network");
    public static void main(String[] args ) {
        String propFileName = null;

        if (args.length > 0) {
            propFileName = args[0];
        } else {
            propFileName = new String("network.conf");
        }    
        try {
            Properties props= new Properties();
            props.load(new FileInputStream(propFileName));
            props.setProperty("org.renci.databridge.primaryQueue",
                              props.getProperty("org.renci.databridge.networkEngine.primaryQueue"));
            logger.log(Level.INFO, 
                "primaryQueue set to: " + props.getProperty("org.renci.databridge.primaryQueue"));
            NetworkEngineMessageListener aml = 
                new NetworkEngineMessageListener (props, new NetworkEngineMessage(), 
                                                  new NetworkEngineMessageHandler(), logger);
            aml.start ();

            // Start a second thread to listen for actionable messages.
            // We need to reset the org.renci.databridge.primaryQueue property. This is the queue
            // this listener will listen to.
            props.setProperty("org.renci.databridge.primaryQueue",
                              props.getProperty("org.renci.databridge.networkEngine.ingestQueue"));
            logger.log(Level.INFO, 
                "primaryQueue set to: " + props.getProperty("org.renci.databridge.primaryQueue"));

            NetworkEngineMessageListener networkListener = 
                new NetworkEngineMessageListener (props, new NetworkListenerMessage(), 
                                                  new NetworkEngineMessageHandler(), logger);
            networkListener.start ();
            networkListener.join (); // keeps main thread from exiting 
            aml.join (); // keeps main thread from exiting 
        } catch (Exception ex) {
            System.out.println(ex.toString());
            System.exit(1);
        }

    }
}
{'fraction_non_alphanumeric': 0.09349821997376803, 'fraction_numerical': 0.0011242270938729624, 'mean_word_length': 2.1887694145758663, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 8, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2019787', 'n_tokens_mistral': 1299, 'n_tokens_neox': 1231, 'n_words': 348}