Package org.apache.avro.ipc
Class HttpTransceiver
java.lang.Object
org.apache.avro.ipc.Transceiver
org.apache.avro.ipc.HttpTransceiver
- All Implemented Interfaces:
Closeable
,AutoCloseable
An HTTP-based
Transceiver
implementation.-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionCalled by the default definition ofTransceiver.transceive(List)
.void
setTimeout
(int timeout) Set the connect and read timeouts, in milliseconds.void
writeBuffers
(List<ByteBuffer> buffers) Called byRequestor.request(String,Object)
for one-way messages.Methods inherited from class org.apache.avro.ipc.Transceiver
close, getRemote, isConnected, lockChannel, setRemote, transceive, transceive, unlockChannel
-
Constructor Details
-
HttpTransceiver
-
HttpTransceiver
-
-
Method Details
-
setTimeout
public void setTimeout(int timeout) Set the connect and read timeouts, in milliseconds. -
getRemoteName
- Specified by:
getRemoteName
in classTransceiver
-
readBuffers
Description copied from class:Transceiver
Called by the default definition ofTransceiver.transceive(List)
.- Specified by:
readBuffers
in classTransceiver
- Throws:
IOException
-
writeBuffers
Description copied from class:Transceiver
Called byRequestor.request(String,Object)
for one-way messages.- Specified by:
writeBuffers
in classTransceiver
- Throws:
IOException
-