InvocationListener.java

Go to the documentation of this file.

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

import com.griddynamics.jagger.invoker.InvocationException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;

public abstract class InvocationListener<Q, R, E>  {

    public void onStart(InvocationInfo<Q, R, E> invocationInfo){
    }

    public void onSuccess(InvocationInfo<Q, R, E> invocationInfo){
    }

    public void onFail(InvocationInfo<Q, R, E> invocationInfo, InvocationException e){
    }

    public void onError(InvocationInfo<Q, R, E> invocationInfo, Throwable error){
    }

    public static class Composer<Q, R, E> extends InvocationListener<Q, R, E>{
        private static Logger log = LoggerFactory.getLogger(Composer.class);

        private List<InvocationListener<Q, R, E>> listeners;

        public Composer(List<InvocationListener<Q, R, E>> listeners) {
            this.listeners = listeners;
        }

        public static <Q, R, E>InvocationListener compose(List<InvocationListener<Q, R, E>> listeners){
            return new Composer<Q, R, E>(listeners);
        }

        @Override
        public void onStart(InvocationInfo<Q, R, E> invocationInfo) {
            for (InvocationListener<Q, R, E> listener : listeners){
                try{
                    listener.onStart(invocationInfo);
                }catch (RuntimeException ex){
                    log.error("Failed to call onStart in {} listener-invocation", listener.toString(), ex);
                }
            }
        }

        @Override
        public void onSuccess(InvocationInfo<Q, R, E> invocationInfo) {
            for (InvocationListener<Q, R, E> listener : listeners){
                try{
                    listener.onSuccess(invocationInfo);
                }catch (RuntimeException ex){
                    log.error("Failed to call onSuccess in {} listener-invocation", listener.toString(), ex);
                }
            }
        }

        @Override
        public void onFail(InvocationInfo<Q, R, E> invocationInfo, InvocationException e) {
            for (InvocationListener<Q, R, E> listener : listeners){
                try{
                    listener.onFail(invocationInfo, e);
                }catch (RuntimeException ex){
                    log.error("Failed to call onFail in {} listener-invocation", listener.toString(), ex);
                }
            }
        }

        @Override
        public void onError(InvocationInfo<Q, R, E> invocationInfo, Throwable error) {
            for (InvocationListener<Q, R, E> listener : listeners){
                try{
                    listener.onError(invocationInfo, error);
                }catch (RuntimeException ex){
                    log.error("Failed to call onError in {} listener-invocation", listener.toString(), ex);
                }
            }
        }
    }
}