Package org.apache.thrift.transport
Class TSocket
- java.lang.Object
-
- org.apache.thrift.transport.TTransport
-
- org.apache.thrift.transport.TIOStreamTransport
-
- org.apache.thrift.transport.TSocket
-
public class TSocket extends TIOStreamTransport
Socket implementation of the TTransport interface. To be commented soon!
-
-
Field Summary
-
Fields inherited from class org.apache.thrift.transport.TIOStreamTransport
inputStream_, outputStream_
-
-
Constructor Summary
Constructors Constructor Description TSocket(java.lang.String host, int port)
Creates a new unconnected socket that will connect to the given host on the given port.TSocket(java.lang.String host, int port, int timeout)
Creates a new unconnected socket that will connect to the given host on the given port.TSocket(java.net.Socket socket)
Constructor that takes an already created socket.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Closes the socket.java.net.Socket
getSocket()
Returns a reference to the underlying socket.boolean
isOpen()
Checks whether the socket is connected.void
open()
Connects the socket, creating a new socket object if necessary.void
setTimeout(int timeout)
Sets the socket timeout-
Methods inherited from class org.apache.thrift.transport.TIOStreamTransport
flush, read, write
-
Methods inherited from class org.apache.thrift.transport.TTransport
consumeBuffer, getBuffer, getBufferPosition, getBytesRemainingInBuffer, peek, readAll, write
-
-
-
-
Constructor Detail
-
TSocket
public TSocket(java.net.Socket socket) throws TTransportException
Constructor that takes an already created socket.- Parameters:
socket
- Already created socket object- Throws:
TTransportException
- if there is an error setting up the streams
-
TSocket
public TSocket(java.lang.String host, int port)
Creates a new unconnected socket that will connect to the given host on the given port.- Parameters:
host
- Remote hostport
- Remote port
-
TSocket
public TSocket(java.lang.String host, int port, int timeout)
Creates a new unconnected socket that will connect to the given host on the given port.- Parameters:
host
- Remote hostport
- Remote porttimeout
- Socket timeout
-
-
Method Detail
-
setTimeout
public void setTimeout(int timeout)
Sets the socket timeout- Parameters:
timeout
- Milliseconds timeout
-
getSocket
public java.net.Socket getSocket()
Returns a reference to the underlying socket.
-
isOpen
public boolean isOpen()
Checks whether the socket is connected.- Overrides:
isOpen
in classTIOStreamTransport
- Returns:
- true
-
open
public void open() throws TTransportException
Connects the socket, creating a new socket object if necessary.- Overrides:
open
in classTIOStreamTransport
- Throws:
TTransportException
- if the transport could not be opened
-
close
public void close()
Closes the socket.- Overrides:
close
in classTIOStreamTransport
-
-