| | |
| | | package com.genersoft.iot.vmp.gb28181; |
| | | |
| | | import java.text.ParseException;
|
| | | import java.util.Properties; |
| | | |
| | | import javax.annotation.PostConstruct; |
| | |
| | | * 0; public static final int TRACE_MESSAGES = 16; public static final int |
| | | * TRACE_EXCEPTION = 17; public static final int TRACE_DEBUG = 32; |
| | | */ |
| | | properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL", "0"); |
| | | properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL", "32");
|
| | | properties.setProperty("gov.nist.javax.sip.SERVER_LOG", "sip_server_log"); |
| | | properties.setProperty("gov.nist.javax.sip.DEBUG_LOG", "sip_debug_log"); |
| | | sipStack = (SipStackImpl) sipFactory.createSipStack(properties); |
| | |
| | | } |
| | | |
| | | private void startTcpListener() throws Exception { |
| | | ListeningPoint tcpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "TCP"); |
| | | ListeningPoint tcpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(),
|
| | | "TCP");
|
| | | tcpSipProvider = sipStack.createSipProvider(tcpListeningPoint); |
| | | tcpSipProvider.addSipListener(this); |
| | | } |
| | | |
| | | private void startUdpListener() throws Exception { |
| | | ListeningPoint udpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "UDP"); |
| | | ListeningPoint udpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(),
|
| | | "UDP");
|
| | | udpSipProvider = sipStack.createSipProvider(udpListeningPoint); |
| | | udpSipProvider.addSipListener(this); |
| | | } |
| | |
| | | int status = response.getStatusCode(); |
| | | if ((status >= 200) && (status < 300)) { // Success! |
| | | ISIPResponseProcessor processor = processorFactory.createResponseProcessor(evt); |
| | | try {
|
| | | processor.process(evt, this, sipConfig); |
| | | } catch (ParseException e) {
|
| | | // TODO Auto-generated catch block
|
| | | e.printStackTrace();
|
| | | }
|
| | | // } else if (status == Response.TRYING) {
|
| | | // trying不会回复
|
| | | } else if ((status >= 100) && (status < 200)) {
|
| | | // 增加其它无需回复的响应,如101、180等
|
| | | } else { |
| | | logger.warn("接收到失败的response响应!status:" + status + ",message:" + response.getContent().toString()); |
| | | logger.warn("接收到失败的response响应!status:" + status + ",message:" + response.getReasonPhrase()/* .getContent().toString()*/);
|
| | | } |
| | | // trying不会回复 |
| | | if (status == Response.TRYING) { |
| | | // if (status == Response.TRYING) {
|
| | | |
| | | } |
| | | // }
|
| | | } |
| | | |
| | | /** |