TestGroupDecisionMakerListener.java

Go to the documentation of this file.

package com.griddynamics.jagger.engine.e1.collector.testgroup;

import com.griddynamics.jagger.util.Decision;
import com.griddynamics.jagger.engine.e1.sessioncomparation.WorstCaseDecisionMaker;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.List;

public interface TestGroupDecisionMakerListener {
    Decision onDecisionMaking(TestGroupDecisionMakerInfo decisionMakerInfo);

    public static class Composer implements TestGroupDecisionMakerListener{
        private static Logger log = LoggerFactory.getLogger(Composer.class);

        private List<TestGroupDecisionMakerListener> listenerList;

        private Composer(List<TestGroupDecisionMakerListener> listenerList){
            this.listenerList = listenerList;
        }

        @Override
        public Decision onDecisionMaking(TestGroupDecisionMakerInfo decisionMakerInfo) {
            List<Decision> decisions = new ArrayList<Decision>();

            WorstCaseDecisionMaker worstCaseDecisionMaker = new WorstCaseDecisionMaker();

            for (TestGroupDecisionMakerListener listener : listenerList){
                try{
                    decisions.add(listener.onDecisionMaking(decisionMakerInfo));
                }catch (RuntimeException ex){
                    log.error("Failed to call on decision making in {} test-group-decision-maker-listener", listener.toString(), ex);
                }
            }

            return worstCaseDecisionMaker.getDecision(decisions);
        }
        public static TestGroupDecisionMakerListener compose(List<TestGroupDecisionMakerListener> listeners){
            return new Composer(listeners);
        }
    }
}