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
ConstructorsConstructorDescriptionSocketTransceiver(SocketAddress address) Deprecated.SocketTransceiver(SocketChannel channel) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()Deprecated.org.apache.avro.ProtocolDeprecated.Returns the protocol passed toTransceiver.setRemote(Protocol).Deprecated.booleanDeprecated.True if a handshake has been completed for this connection.Deprecated.Called by the default definition ofTransceiver.transceive(List).voidsetRemote(org.apache.avro.Protocol remote) Deprecated.Called with the remote protocol when a handshake has been completed.voidwriteBuffers(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:
getRemoteNamein classTransceiver
-
readBuffers
Deprecated.Description copied from class:TransceiverCalled by the default definition ofTransceiver.transceive(List).- Specified by:
readBuffersin classTransceiver- Throws:
IOException
-
writeBuffers
Deprecated.Description copied from class:TransceiverCalled byRequestor.request(String,Object)for one-way messages.- Specified by:
writeBuffersin classTransceiver- Throws:
IOException
-
isConnected
public boolean isConnected()Deprecated.Description copied from class:TransceiverTrue 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:
isConnectedin classTransceiver
-
setRemote
public void setRemote(org.apache.avro.Protocol remote) Deprecated.Description copied from class:TransceiverCalled 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:
setRemotein classTransceiver
-
getRemote
public org.apache.avro.Protocol getRemote()Deprecated.Description copied from class:TransceiverReturns the protocol passed toTransceiver.setRemote(Protocol). Throws IllegalStateException by default.- Overrides:
getRemotein classTransceiver
-
close
Deprecated.- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classTransceiver- Throws:
IOException
-
SaslSocketTransceiverinstead.