//package com.example.stream.core.stream;
//
//import com.github.microservice.app.stream.StreamConsumer;
//import com.nr.flow.client.model.event.TaskParameterModel;
//import org.springframework.stereotype.Component;
//
//import java.util.Map;
//
//@Component("flowEngineStreamConsumer")
//public class FlowEngineStream extends StreamConsumer<TaskParameterModel> {
//
//
//    @Override
//    public void accept(TaskParameterModel taskParameterModel) {
//        System.out.println(taskParameterModel);
//    }
//}
