Ignore:
Timestamp:
06/11/20 16:34:40 (4 years ago)
Author:
bart
Message:

Update to version 1.41

File:
1 edited

Legend:

Unmodified
Added
Removed
  • simplerunner/src/main/java/geniusweb/simplerunner/NegoRunner.java

    r10 r18  
    77import java.util.logging.Level;
    88
     9import com.fasterxml.jackson.core.JsonProcessingException;
    910import com.fasterxml.jackson.databind.ObjectMapper;
    1011
     
    1314import geniusweb.protocol.NegoProtocol;
    1415import geniusweb.protocol.NegoSettings;
     16import geniusweb.protocol.NegoState;
    1517import geniusweb.protocol.partyconnection.ProtocolToPartyConnFactory;
    16 import tudelft.utilities.logging.ReportToLogger;
    1718import tudelft.utilities.logging.Reporter;
    1819
     
    2728        private final NegoProtocol protocol;
    2829        private final ProtocolToPartyConnFactory connectionfactory;
    29         private final Reporter log;
     30        protected final Reporter log;
    3031        private final static ObjectMapper jackson = new ObjectMapper();
    3132
     
    5556
    5657        protected void stop() {
    57                 if (protocol.getState().getError() != null) {
    58                         log.log(Level.WARNING, "protocol terminated abnormally",
    59                                         protocol.getState().getError());
    60                 } else {
    61                         log.log(Level.INFO,
    62                                         "protocol ended normally: " + protocol.getState());
     58                Level level = protocol.getState().getError() == null ? Level.INFO
     59                                : Level.WARNING;
     60                logFinal(level, protocol.getState());
     61        }
     62
     63        /**
     64         * Separate so that we can intercept this when mocking, as this will crash
     65         * on mocks
     66         *
     67         * @param level
     68         * @param state
     69         */
     70        protected void logFinal(Level level, NegoState state) {
     71                try {
     72                        log.log(level, "protocol ended normally: "
     73                                        + jackson.writeValueAsString(protocol.getState()));
     74                } catch (JsonProcessingException e) {
     75                        e.printStackTrace();
    6376                }
    6477        }
     
    7588
    7689                NegoRunner runner = new NegoRunner(settings,
    77                                 new ClassPathConnectionFactory(),
    78                                 new ReportToLogger("sessionrunner"));
     90                                new ClassPathConnectionFactory(), new StdOutReporter());
    7991                runner.run();
    8092        }
     
    90102        }
    91103}
     104
     105class StdOutReporter implements Reporter {
     106
     107        @Override
     108        public void log(Level arg0, String arg1) {
     109                System.out.println(arg0 + ":" + arg1);
     110        }
     111
     112        @Override
     113        public void log(Level arg0, String arg1, Throwable arg2) {
     114                System.out.println(arg0 + ">" + arg1);
     115        }
     116
     117}
Note: See TracChangeset for help on using the changeset viewer.