ra.net

Class SendProcessor

java.lang.Object

ra.net.SendProcessor

All Implemented Interfaces:

java.lang.Runnable, Sendable<java.lang.String>

public class SendProcessor
extends java.lang.Object
implements java.lang.Runnable, Sendable<java.lang.String>

Provide sent message from the queue.

Author:

Ray Li, Kevin Tasi

Constructor Summary

Constructors

Constructor and Description
SendProcessor(NetServiceable service) Initialize.
SendProcessor(NetServiceable service, java.net.Socket socket, int timeout) Initialize.

Method Summary

Modifier and Type	Method and Description
void	clearQueue() Clear message in queue.
void	close() Close and clear message in queue.
java.lang.String	getIp() Returns IP address.
boolean	getSendCompilete() Return whether completed that sent the message.
void	run()
void	send(java.lang.String message) Send message.
void	sendClose(java.lang.String message) Close the connection after sent the message.
void	setSoTimeout(int timeout) Set timeout value.

Methods inherited from class java.lang.Object

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

Constructor Detail

SendProcessor

public SendProcessor(NetServiceable service,
                     java.net.Socket socket,
                     int timeout)
              throws java.io.IOException

Initialize.

Parameters:

service - service

socket - socket

timeout - timeout

Throws:

java.io.IOException - IOException

SendProcessor

public SendProcessor(NetServiceable service)

Initialize.

Parameters:

service - service

Method Detail

clearQueue

public void clearQueue()

Clear message in queue.

close

public void close()

Close and clear message in queue.

run

public void run()

Specified by:

run in interface java.lang.Runnable

send

public void send(java.lang.String message)

Send message.

Specified by:

send in interface Sendable<java.lang.String>

Parameters:

message - message

sendClose

public void sendClose(java.lang.String message)

Close the connection after sent the message.

Specified by:

sendClose in interface Sendable<java.lang.String>

Parameters:

message - message

getIp

public java.lang.String getIp()

Returns IP address.

Returns:

IP address

setSoTimeout

public void setSoTimeout(int timeout)
                  throws java.net.SocketException

Set timeout value.

Parameters:

timeout - timeout

Throws:

java.net.SocketException - SocketException

getSendCompilete

public boolean getSendCompilete()

Return whether completed that sent the message.

Returns:

whether sent completed