panlinlin
2021-03-30 56859d09df8d4226882d43934acf32d60a3b51d7
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/callback/DeferredResultHolder.java
@@ -1,7 +1,7 @@
package com.genersoft.iot.vmp.gb28181.transmit.callback;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
@@ -9,14 +9,23 @@
import org.springframework.web.context.request.async.DeferredResult;
/**    
 * @Description:TODO(这里用一句话描述这个类的作用)
 * @Description: 异步请求处理
 * @author: swwheihei
 * @date:   2020年5月8日 下午7:59:05     
 */
@SuppressWarnings(value = {"rawtypes", "unchecked"})
@Component
public class DeferredResultHolder {
   
   public static final String CALLBACK_CMD_DEVICESTATUS = "CALLBACK_DEVICESTATUS";
   public static final String CALLBACK_CMD_DEVICEINFO = "CALLBACK_DEVICEINFO";
   public static final String CALLBACK_CMD_DEVICECONTROL = "CALLBACK_DEVICECONTROL";
   public static final String CALLBACK_CMD_DEVICECONFIG = "CALLBACK_DEVICECONFIG";
   public static final String CALLBACK_CMD_CONFIGDOWNLOAD = "CALLBACK_CONFIGDOWNLOAD";
   
   public static final String CALLBACK_CMD_CATALOG = "CALLBACK_CATALOG";
   
@@ -24,8 +33,18 @@
   public static final String CALLBACK_CMD_PlAY = "CALLBACK_PLAY";
   private Map<String, DeferredResult> map = new HashMap<String, DeferredResult>();
   public static final String CALLBACK_CMD_STOP = "CALLBACK_STOP";
   public static final String CALLBACK_CMD_MOBILEPOSITION = "CALLBACK_MOBILEPOSITION";
   public static final String CALLBACK_CMD_PRESETQUERY = "CALLBACK_PRESETQUERY";
   public static final String CALLBACK_CMD_ALARM = "CALLBACK_ALARM";
   public static final String CALLBACK_CMD_BROADCAST = "CALLBACK_BROADCAST";
   private Map<String, DeferredResult> map = new ConcurrentHashMap<String, DeferredResult>();
   public void put(String key, DeferredResult result) {
      map.put(key, result);
   }