Package com.epam.common.transport

Class SocketTransport

java.lang.Object

com.epam.common.transport.SocketTransport

All Implemented Interfaces:

Transport

Direct Known Subclasses:

TCPTransport

public abstract class SocketTransport
extends Object
implements Transport

Abstract socket implementation of transport.

Field Summary

Fields

Modifier and Type	Field	Description
protected InputStream	is
protected OutputStream	os
protected int	receiveBufferSize
protected int	sendBufferSize
protected Socket	socket

Constructor Summary

Constructors

Constructor	Description
SocketTransport()

Method Summary

Modifier and Type	Method	Description
void	close()	Close the transport.
String	getAddress()	Getter for address value.
InetAddress	getInetAddress()	Getter for address value.
InputStream	getInputStream()
int	getLocalPort()	Getter for local port value.
OutputStream	getOutputStream()	Gets output stream.
int	getPort()	Getter for port value.
Certificate[]	getSSLCertificates()	Getter for certificates from session
String	getSSLCipherSuite()	Getter for cipher suite from session
String	getSSLProtocol()	Getter for ssl protocol from session
boolean	isBlockingSocket()
boolean	isOpen()	Returns true if, transport is open.
abstract void	open()	Open the transport.
int	read(byte[] buffer)	Transport dependent read method.
int	read(byte[] buffer, int offset, int length)	Transport dependent read method.
int	read(ByteBuffer buffer)
int	read(ByteBuffer buffer, int offset, int length)
void	waitUntilReadyToWrite()
void	write(byte[] message)	Transport dependent write method.
int	write(byte[] message, int offset, int length)	Transport dependent write method.
int	write(ByteBuffer buffer)
int	write(ByteBuffer buffer, int offset, int length)

Methods inherited from class java.lang.Object

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

Field Details

socket

protected Socket socket

is

protected InputStream is

os

protected OutputStream os

sendBufferSize

protected int sendBufferSize

receiveBufferSize

protected int receiveBufferSize

Constructor Details

SocketTransport

public SocketTransport()

Method Details

getInputStream

public InputStream getInputStream()

isBlockingSocket

public boolean isBlockingSocket()

Specified by:

isBlockingSocket in interface Transport

getOutputStream

public OutputStream getOutputStream()

Gets output stream.

Returns:

output stream

read

public int read(byte[] buffer,
 int offset,
 int length)
         throws IOException

Description copied from interface: Transport

Transport dependent read method.

Specified by:

read in interface Transport

Parameters:

buffer - holder for read bytes

offset - in buffer

length - maximum bytes to be read

Returns:

number of byte actually read

Throws:

IOException - if unable to read

See Also:

• Transport.read(byte[], int, int)

read

public int read(byte[] buffer)
         throws IOException

Description copied from interface: Transport

Transport dependent read method.

Specified by:

read in interface Transport

Parameters:

buffer - holder for read bytes

Returns:

number of byte actually read

Throws:

IOException - if unable to read

See Also:

• Transport.read(byte[])

write

public void write(byte[] message)
           throws IOException

Description copied from interface: Transport

Transport dependent write method.

Specified by:

write in interface Transport

Parameters:

message - actual message

Throws:

IOException - if unable to write

See Also:

• Transport.write(byte[])

write

public int write(byte[] message,
 int offset,
 int length)
          throws IOException

Description copied from interface: Transport

Transport dependent write method.

Specified by:

write in interface Transport

Parameters:

message - actual message

offset - the offset in buffer

length - the num of bytes to write

Throws:

IOException - if unable to write

write

public int write(ByteBuffer buffer)
          throws IOException

Specified by:

write in interface Transport

Throws:

IOException

write

public int write(ByteBuffer buffer,
 int offset,
 int length)
          throws IOException

Specified by:

write in interface Transport

Throws:

IOException

read

public int read(ByteBuffer buffer,
 int offset,
 int length)
         throws IOException

Specified by:

read in interface Transport

Throws:

IOException

read

public int read(ByteBuffer buffer)
         throws IOException

Specified by:

read in interface Transport

Throws:

IOException

waitUntilReadyToWrite

public void waitUntilReadyToWrite()
                           throws IOException

Specified by:

waitUntilReadyToWrite in interface Transport

Throws:

IOException

getAddress

public String getAddress()

Description copied from interface: Transport

Getter for address value.

Specified by:

getAddress in interface Transport

See Also:

• Transport.getAddress()

getInetAddress

public InetAddress getInetAddress()

Description copied from interface: Transport

Getter for address value.

Specified by:

getInetAddress in interface Transport

getPort

public int getPort()

Description copied from interface: Transport

Getter for port value.

Specified by:

getPort in interface Transport

See Also:

• Transport.getPort()

getLocalPort

public int getLocalPort()

Getter for local port value.

Specified by:

getLocalPort in interface Transport

close

public void close()
           throws IOException

Description copied from interface: Transport

Close the transport.

Specified by:

close in interface Transport

Throws:

IOException - - throws if error occurred

See Also:

• Transport.close()

open

public abstract void open()
                   throws IOException

Description copied from interface: Transport

Open the transport.

Specified by:

open in interface Transport

Throws:

IOException - - throws if error occurred

See Also:

• Transport.open()

isOpen

public boolean isOpen()

Description copied from interface: Transport

Returns true if, transport is open.

Specified by:

isOpen in interface Transport

See Also:

• Transport.isOpen()

getSSLProtocol

public String getSSLProtocol()

Description copied from interface: Transport

Getter for ssl protocol from session

Specified by:

getSSLProtocol in interface Transport

getSSLCipherSuite

public String getSSLCipherSuite()

Description copied from interface: Transport

Getter for cipher suite from session

Specified by:

getSSLCipherSuite in interface Transport

getSSLCertificates

public Certificate[] getSSLCertificates()

Description copied from interface: Transport

Getter for certificates from session

Specified by:

getSSLCertificates in interface Transport