lawrencehj
2021-02-05 a8603075d4bfb6ebc3248e6662eb700261c0fa56
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorFactory.java
@@ -8,10 +8,9 @@
import javax.sip.message.Response;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
// import org.slf4j.Logger;
// import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Component;
import com.genersoft.iot.vmp.conf.SipConfig;
@@ -26,6 +25,7 @@
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.CancelRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.InviteRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.MessageRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.NotifyRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.OtherRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.RegisterRequestProcessor;
import com.genersoft.iot.vmp.gb28181.transmit.request.impl.SubscribeRequestProcessor;
@@ -39,14 +39,14 @@
import com.genersoft.iot.vmp.utils.redis.RedisUtil;
/**    
 * @Description:TODO(这里用一句话描述这个类的作用)
 * @Description: SIP信令处理分配
 * @author: swwheihei
 * @date:   2020年5月3日 下午4:24:37     
 */
@Component
public class SIPProcessorFactory {
   
   private final static Logger logger = LoggerFactory.getLogger(SIPProcessorFactory.class);
   // private final static Logger logger = LoggerFactory.getLogger(SIPProcessorFactory.class);
   
   @Autowired
   private SipConfig sipConfig;
@@ -144,6 +144,19 @@
         processor.setStorager(storager);
         processor.setRedisCatchStorage(redisCatchStorage);
         return processor;
      } else if (Request.NOTIFY.equalsIgnoreCase(method)) {
         NotifyRequestProcessor processor = new NotifyRequestProcessor();
         processor.setRequestEvent(evt);
         processor.setTcpSipProvider(getTcpSipProvider());
         processor.setUdpSipProvider(getUdpSipProvider());
         processor.setPublisher(publisher);
         processor.setRedis(redis);
         processor.setDeferredResultHolder(deferredResultHolder);
         processor.setOffLineDetector(offLineDetector);
         processor.setCmder(cmder);
         processor.setStorager(storager);
         processor.setRedisCatchStorage(redisCatchStorage);
         return processor;
      } else {
         OtherRequestProcessor processor = new OtherRequestProcessor();
         processor.setRequestEvent(evt);