moral.git - Gitblit

summary
reflog
commits
tree
tickets
docs
forks
compare

lizijie

2021-10-09 30d475ca8f7f09ab6ad4802add508dd51d9e20a2

 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) {