#

Junjie

9 小时以前 ade2ee628437d38cb7c11dd456a5ea18dff97325

 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("未知的线程实现");
                }
@@ -137,6 +135,8 @@
                    thread = new ZyStationThread(deviceConfig, redisUtil);
                } else if (deviceConfig.getThreadImpl().equals("ZyStationV3Thread")) {
                    thread = new ZyStationV3Thread(deviceConfig, redisUtil);
                } else if (deviceConfig.getThreadImpl().equals("ZyStationV4Thread")) {
                    thread = new ZyStationV4Thread(deviceConfig, redisUtil);
                } else {
                    throw new CoolException("未知的线程实现");
                }