diff --git a/src/main/java/com/sqx/nsqChannel/NsqConfig.java b/src/main/java/com/sqx/nsqChannel/NsqConfig.java index 4ba6d2a6..cfcea39e 100644 --- a/src/main/java/com/sqx/nsqChannel/NsqConfig.java +++ b/src/main/java/com/sqx/nsqChannel/NsqConfig.java @@ -12,18 +12,18 @@ import javax.annotation.PostConstruct; @Service @Slf4j public class NsqConfig { - /** - * 端口号 - */ - @Value("${nsq.port}") - private int port; - - @Value("${nsq.address}") - private String address; - - @PostConstruct - public void startNSQChannel() { - new NSQConsumers(address, port, "test", "ch1", new Print2MessageHandlerAdapter()); - new NSQConsumers(address, port, "test", "ch2", new PrintMessageHandlerAdapter()); - } +// /** +// * 端口号 +// */ +// @Value("${nsq.port}") +// private int port; +// +// @Value("${nsq.address}") +// private String address; +// +// @PostConstruct +// public void startNSQChannel() { +// new NSQConsumers(address, port, "test", "ch1", new Print2MessageHandlerAdapter()); +// new NSQConsumers(address, port, "test", "ch2", new PrintMessageHandlerAdapter()); +// } }