gov.nist.javax.sip.stack
Class TCPMessageProcessor

java.lang.Object
  gov.nist.javax.sip.stack.MessageProcessor
      gov.nist.javax.sip.stack.TCPMessageProcessor

All Implemented Interfaces:

Runnable

public class TCPMessageProcessor

extends MessageProcessor

Sit in a loop waiting for incoming tcp connections and start a new thread to handle each new connection. This is the active object that creates new TCP MessageChannels (one for each new accept socket).

Version:

1.2 $Revision: 1.24 $ $Date: 2006/07/13 09:01:01 $

Author:

M. Ranganathan
Acknowledgement: Jeff Keyser suggested that a Stop mechanism be added to this. Niklas Uhrberg suggested that a means to limit the number of simultaneous active connections should be added. Mike Andrews suggested that the thread be accessible so as to implement clean stop using Thread.join().

Method Summary

MessageChannel	createMessageChannel(gov.nist.core.HostPort targetHostPort) Create a message channel for the specified host/port.
MessageChannel	createMessageChannel(InetAddress host, int port) Create a message channel for the specified host/port.
int	getDefaultTargetPort() Default target port for TCP
int	getMaximumMessageSize() TCP can handle an unlimited number of bytes.
SIPTransactionStack	getSIPStack() Returns the stack.
String	getTransport() Return the transport string.
boolean	inUse() Return true if there are pending messages to be processed (which prevents the message channel from being closed).
boolean	isSecure() TCP is not a secure protocol.
void	run() Run method for the thread that gets created for each accept socket.
void	start() Start the processor.
void	stop() Stop the message processor.

Methods inherited from class gov.nist.javax.sip.stack.MessageProcessor

getDefaultPort, getIPAddress, getListeningPoint, getPort, getSentBy, getViaHeader, isSentBySet, setListeningPoint, setSentBy

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

start

public void start()
           throws IOException

Start the processor.

Specified by:

start in class MessageProcessor

Throws:

IOException

run

public void run()

Run method for the thread that gets created for each accept socket.

Specified by:

run in interface Runnable

Specified by:

run in class MessageProcessor

getTransport

public String getTransport()

Return the transport string.

Overrides:

getTransport in class MessageProcessor

Returns:

the transport string

getSIPStack

public SIPTransactionStack getSIPStack()

Returns the stack.

Specified by:

getSIPStack in class MessageProcessor

Returns:

my sip stack.

stop

public void stop()

Stop the message processor. Feature suggested by Jeff Keyser.

Specified by:

stop in class MessageProcessor

createMessageChannel

public MessageChannel createMessageChannel(gov.nist.core.HostPort targetHostPort)
                                    throws IOException

Description copied from class: MessageProcessor

Create a message channel for the specified host/port.

Specified by:

createMessageChannel in class MessageProcessor

Returns:

New MessageChannel for this processor.

Throws:

IOException

createMessageChannel

public MessageChannel createMessageChannel(InetAddress host,
                                           int port)
                                    throws IOException

Description copied from class: MessageProcessor

Create a message channel for the specified host/port.

Specified by:

createMessageChannel in class MessageProcessor

Returns:

New MessageChannel for this processor.

Throws:

IOException

getMaximumMessageSize

public int getMaximumMessageSize()

TCP can handle an unlimited number of bytes.

Specified by:

getMaximumMessageSize in class MessageProcessor

inUse

public boolean inUse()

Description copied from class: MessageProcessor

Return true if there are pending messages to be processed (which prevents the message channel from being closed).

Specified by:

inUse in class MessageProcessor

getDefaultTargetPort

public int getDefaultTargetPort()

Default target port for TCP

Specified by:

getDefaultTargetPort in class MessageProcessor

isSecure

public boolean isSecure()

TCP is not a secure protocol.

Specified by:

isSecure in class MessageProcessor