ra.net.nio

Class Sender<E>

java.lang.Object

ra.net.nio.Sender<E>

All Implemented Interfaces:

java.lang.Runnable, Sendable<Data>

public class Sender<E>
extends java.lang.Object
implements java.lang.Runnable, Sendable<Data>

Provide sent message use queue.

Author:

Ray Li

Constructor Summary

Constructors

Constructor and Description
Sender(Serviceable<E> listener, Transfer transferListener, java.net.Socket socket, int timeout) Initialize.

Method Summary

Modifier and Type	Method and Description
void	clearQueue() Clear message queue.
void	close() Close and clear message queue.
java.lang.String	getIp() Returns IP address of client.
boolean	isSendClose() Returns send close of the flag.
void	run()
void	send(Data data) Send data.
void	sendClose(Data data) Close sender after sending data.
void	setSoTimeout(int timeout) Enable/disable SO_TIMEOUT with the specified timeout, in milliseconds.

Methods inherited from class java.lang.Object

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

Constructor Detail

Sender

public Sender(Serviceable<E> listener,
              Transfer transferListener,
              java.net.Socket socket,
              int timeout)
       throws java.io.IOException

Initialize.

Parameters:

listener - close event

transferListener - transfer

socket - connection

timeout - connection read timeout

Throws:

java.io.IOException - Throw IOException when the connection failed.

Method Detail

clearQueue

public void clearQueue()

Clear message queue.

close

public void close()

Close and clear message queue.

run

public void run()

Specified by:

run in interface java.lang.Runnable

send

public void send(Data data)

Send data.

Specified by:

send in interface Sendable<Data>

Parameters:

data - text or file

sendClose

public void sendClose(Data data)

Close sender after sending data.

Specified by:

sendClose in interface Sendable<Data>

Parameters:

data - message

getIp

public java.lang.String getIp()

Returns IP address of client.

Returns:

IP address

setSoTimeout

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

Enable/disable SO_TIMEOUT with the specified timeout, in milliseconds.

Parameters:

timeout - timeout

Throws:

java.net.SocketException - SocketException

isSendClose

public boolean isSendClose()

Returns send close of the flag.

Returns:

flag