moral.git - Gitblit

summary
reflog
commits
tree
tickets
docs
forks
compare

kaiyu

2021-09-13 10d4b885a9b2af2a38bb03249d7547283f948197

 screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java

@@ -39,7 +39,6 @@
    public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
        String messageStr = record.value();
        Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr);
        log.info(message.toString());
        //long serverStartTime = System.currentTimeMillis();
        CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
        for (SingleDeviceServer socket : sockets) {

			@@ -39,7 +39,6 @@
			public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
			String messageStr = record.value();
			Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr);
			log.info(message.toString());
			//long serverStartTime = System.currentTimeMillis();
			CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
			for (SingleDeviceServer socket : sockets) {