|  |  |  | 
|---|
|  |  |  | package com.genersoft.iot.vmp.gb28181.transmit.callback; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.util.HashMap; | 
|---|
|  |  |  | import java.util.Map; | 
|---|
|  |  |  | import java.util.concurrent.ConcurrentHashMap; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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_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); | 
|---|
|  |  |  | } | 
|---|