#

Junjie

2 天以前 99bb8ae0205c6de1fb58751e3ee8868c795456c1

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -8,11 +8,7 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.thread.impl.ZySiemensCrnThread;
import com.zy.core.thread.impl.ZySiemensDualCrnThread;
import com.zy.core.thread.impl.ZyStationThread;
import com.zy.core.thread.impl.ZyStationV3Thread;
import com.zy.core.thread.impl.ZyRgvThread;
import com.zy.core.thread.impl.*;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -95,6 +91,8 @@
                ThreadHandler thread = null;
                if (deviceConfig.getThreadImpl().equals("ZySiemensCrnThread")) {
                    thread = new ZySiemensCrnThread(deviceConfig, redisUtil);
                } else if (deviceConfig.getThreadImpl().equals("ZySiemensCrnV2Thread")) {
                    thread = new ZySiemensCrnV2Thread(deviceConfig, redisUtil);
                } else {
                    throw new CoolException("未知的线程实现");
                }