package cn.axzo.workflow.starter.handler.execute.interceptor;

import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.workflow.starter.handler.execute.ListenerExecutor;

import java.util.function.Consumer;

public interface ExecuteInterceptor {

    <T> void execute(ListenerExecutor executor, Consumer<T> consumer, EventConsumer.Context context, T t);

    ExecuteInterceptor getNext();

    void setNext(ExecuteInterceptor next);
}
