修复 流已经关闭后，再次调用关闭流的接口，返回超时

panlinlin

2021-04-16 c5f2aba9b20089f184ce175b58a33a881ea9e0b1

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/callback/DeferredResultHolder.java

@@ -1,6 +1,5 @@
package com.genersoft.iot.vmp.gb28181.transmit.callback;



import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.ConcurrentHashMap;



@@ -10,10 +9,11 @@
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 {

   

@@ -41,8 +41,10 @@


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

   }