Package org.apache.avro.ipc
Class SocketTransceiver
java.lang.Object
org.apache.avro.ipc.Transceiver
org.apache.avro.ipc.SocketTransceiver
- All Implemented Interfaces:
Closeable
,AutoCloseable
Deprecated.
A socket-based
Transceiver
implementation. This uses a simple,
non-standard wire protocol and is not intended for production services.-
Constructor Summary
ConstructorDescriptionSocketTransceiver
(SocketAddress address) Deprecated.SocketTransceiver
(SocketChannel channel) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
Deprecated.Deprecated.Returns the protocol passed toTransceiver.setRemote(Protocol)
.Deprecated.boolean
Deprecated.True if a handshake has been completed for this connection.Deprecated.Called by the default definition ofTransceiver.transceive(List)
.void
Deprecated.Called with the remote protocol when a handshake has been completed.void
writeBuffers
(List<ByteBuffer> buffers) Deprecated.Called byRequestor.request(String,Object)
for one-way messages.Methods inherited from class org.apache.avro.ipc.Transceiver
lockChannel, transceive, transceive, unlockChannel
-
Constructor Details
-
SocketTransceiver
Deprecated.- Throws:
IOException
-
SocketTransceiver
Deprecated.- Throws:
IOException
-
-
Method Details
-
getRemoteName
Deprecated.- Specified by:
getRemoteName
in classTransceiver
-
readBuffers
Deprecated.Description copied from class:Transceiver
Called by the default definition ofTransceiver.transceive(List)
.- Specified by:
readBuffers
in classTransceiver
- Throws:
IOException
-
writeBuffers
Deprecated.Description copied from class:Transceiver
Called byRequestor.request(String,Object)
for one-way messages.- Specified by:
writeBuffers
in classTransceiver
- Throws:
IOException
-
isConnected
public boolean isConnected()Deprecated.Description copied from class:Transceiver
True if a handshake has been completed for this connection. Used to determine whether a handshake need be completed prior to a one-way message. Requests and responses are always prefixed by handshakes, but one-way messages. If the first request sent over a connection is one-way, then a handshake-only response is returned. Subsequent one-way messages over the connection will have no response data sent. Returns false by default.- Overrides:
isConnected
in classTransceiver
-
setRemote
Deprecated.Description copied from class:Transceiver
Called with the remote protocol when a handshake has been completed. After this has been called and while a connection is maintained,Transceiver.isConnected()
should return true and #getRemote() should return this protocol. Does nothing by default.- Overrides:
setRemote
in classTransceiver
-
getRemote
Deprecated.Description copied from class:Transceiver
Returns the protocol passed toTransceiver.setRemote(Protocol)
. Throws IllegalStateException by default.- Overrides:
getRemote
in classTransceiver
-
close
Deprecated.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classTransceiver
- Throws:
IOException
-
SaslSocketTransceiver
instead.