Package | Description |
---|---|
org.apache.avro.ipc |
Support for inter-process calls.
|
org.apache.avro.ipc.netty |
Modifier and Type | Class and Description |
---|---|
class |
CallFuture<T>
A Future implementation for RPCs.
|
protected class |
Requestor.TransceiverCallback<T>
Handles callbacks from transceiver invocations.
|
Modifier and Type | Method and Description |
---|---|
<T> void |
Requestor.request(String messageName,
Object request,
Callback<T> callback)
Writes a request message and returns the result through a Callback.
|
void |
Transceiver.transceive(List<ByteBuffer> request,
Callback<List<ByteBuffer>> callback)
Called by
Requestor.request(String,Object,Callback) for two-way
messages using callbacks. |
Constructor and Description |
---|
CallFuture(Callback<T> chainedCallback)
Creates a CallFuture with a chained Callback which will be invoked when this
CallFuture's Callback methods are invoked.
|
TransceiverCallback(org.apache.avro.ipc.Requestor.Request request,
Callback<T> callback)
Creates a TransceiverCallback.
|
Modifier and Type | Field and Description |
---|---|
protected Callback<List<ByteBuffer>> |
NettyTransceiver.WriteFutureListener.callback |
Modifier and Type | Method and Description |
---|---|
void |
NettyTransceiver.transceive(List<ByteBuffer> request,
Callback<List<ByteBuffer>> callback) |
Constructor and Description |
---|
WriteFutureListener(Callback<List<ByteBuffer>> callback)
Creates a WriteFutureListener that notifies the given callback if an error
occurs writing data to the channel.
|
Copyright © 2009–2022 The Apache Software Foundation. All rights reserved.