Searched refs:messageProcessor (Results 1 – 8 of 8) sorted by relevance
173 UDPMessageProcessor messageProcessor) { in UDPMessageChannel() argument174 super.messageProcessor = messageProcessor; in UDPMessageChannel()179 this.myAddress = messageProcessor.getIpAddress().getHostAddress(); in UDPMessageChannel()180 this.myPort = messageProcessor.getPort(); in UDPMessageChannel()200 UDPMessageProcessor messageProcessor, DatagramPacket packet) { in UDPMessageChannel() argument203 super.messageProcessor = messageProcessor; in UDPMessageChannel()206 this.myAddress = messageProcessor.getIpAddress().getHostAddress(); in UDPMessageChannel()207 this.myPort = messageProcessor.getPort(); in UDPMessageChannel()227 SIPTransactionStack sipStack, UDPMessageProcessor messageProcessor) { in UDPMessageChannel() argument231 super.messageProcessor = messageProcessor; in UDPMessageChannel()[all …]
85 protected transient MessageProcessor messageProcessor; field in MessageChannel186 if (this.messageProcessor != null) in getPort()187 return messageProcessor.getPort(); in getPort()205 for (MessageProcessor messageProcessor : getSIPStack().getMessageProcessors()) { in sendMessage()206 if (messageProcessor.getIpAddress().equals(hopAddr) in sendMessage()207 && messageProcessor.getPort() == hop.getPort() in sendMessage()208 && messageProcessor.getTransport().equals(hop.getTransport())) { in sendMessage()209 MessageChannel messageChannel = messageProcessor.createMessageChannel( in sendMessage()487 return this.messageProcessor; in getMessageProcessor()
156 super.messageProcessor = msgProcessor; in TLSMessageChannel()170 TLSMessageProcessor messageProcessor) throws IOException { in TLSMessageChannel() argument177 this.myPort = messageProcessor.getPort(); in TLSMessageChannel()180 this.tlsMessageProcessor = messageProcessor; in TLSMessageChannel()181 this.myAddress = messageProcessor.getIpAddress().getHostAddress(); in TLSMessageChannel()183 super.messageProcessor = messageProcessor; in TLSMessageChannel()308 Socket sock = this.sipStack.ioHandler.sendBytes(this.messageProcessor.getIpAddress(), in sendMessage()436 ((TLSMessageProcessor) this.messageProcessor).cacheMessageChannel(this); in processMessage()460 this.messageProcessor.getIpAddress().getHostAddress() + ":" in processMessage()461 + this.messageProcessor.getPort(), false, receptionTime); in processMessage()
141 super.messageProcessor = msgProcessor; in TCPMessageChannel()155 TCPMessageProcessor messageProcessor) throws IOException { in TCPMessageChannel() argument162 this.myPort = messageProcessor.getPort(); in TCPMessageChannel()165 this.tcpMessageProcessor = messageProcessor; in TCPMessageChannel()166 this.myAddress = messageProcessor.getIpAddress().getHostAddress(); in TCPMessageChannel()169 super.messageProcessor = messageProcessor; in TCPMessageChannel()252 Socket sock = this.sipStack.ioHandler.sendBytes(this.messageProcessor.getIpAddress(), in sendMessage()310 Socket sock = this.sipStack.ioHandler.sendBytes(this.messageProcessor.getIpAddress(), in sendMessage()465 ((TCPMessageProcessor) this.messageProcessor).cacheMessageChannel(this); in processMessage()
292 this.messageProcessor = newChannelToUse.messageProcessor; in SIPClientTransaction()
69 protected MessageProcessor messageProcessor; field in ListeningPointImpl167 return messageProcessor.getPort(); in getPort()176 return messageProcessor.getTransport(); in getTransport()193 return this.messageProcessor.getIpAddress().getHostAddress(); in getIPAddress()202 this.messageProcessor.setSentBy(sentBy); in setSentBy()211 return this.messageProcessor.getSentBy(); in getSentBy()215 return this.messageProcessor.isSentBySet(); in isSentBySet()218 return this.messageProcessor.getViaHeader(); in getViaHeader()222 return this.messageProcessor; in getMessageProcessor()251 MessageChannel messageChannel = this.messageProcessor.createMessageChannel(targetHostPort); in sendHeartbeat()
1098 MessageProcessor messageProcessor = this in createListeningPoint() local1107 lip.messageProcessor = messageProcessor; in createListeningPoint()1108 messageProcessor.setListeningPoint(lip); in createListeningPoint()1111 messageProcessor.start(); in createListeningPoint()1158 super.removeMessageProcessor(lip.messageProcessor); in deleteListeningPoint()
1055 if (lp.messageProcessor.inUse()) in removeListeningPoint()1069 lp.messageProcessor.stop(); in removeListeningPoints()