MqttCache.java 462 B

1234567891011121314151617
  1. package com.gyee.dataadapter.cache;
  2. import com.gyee.dataadapter.entity.PointData;
  3. import com.gyee.dataadapter.entity.PointInfo;
  4. import org.springframework.stereotype.Component;
  5. import java.util.HashMap;
  6. import java.util.Map;
  7. import java.util.concurrent.ConcurrentHashMap;
  8. @Component
  9. public class MqttCache {
  10. public static Map<String, PointInfo> subData = new HashMap<>();
  11. public static Map<String, PointData> subData2 = new ConcurrentHashMap<>();
  12. }