Package | Description |
---|---|
org.apache.avro.ipc |
Support for inter-process calls.
|
org.apache.avro.ipc.generic | |
org.apache.avro.ipc.trace |
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 | Field and Description |
---|---|
protected Callback<List<ByteBuffer>> |
NettyTransceiver.WriteFutureListener.callback |
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 |
NettyTransceiver.transceive(List<ByteBuffer> request,
Callback<List<ByteBuffer>> 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.
|
NettyTransceiver.WriteFutureListener(Callback<List<ByteBuffer>> callback)
Creates a WriteFutureListener that notifies the given callback
if an error occurs writing data to the channel.
|
Requestor.TransceiverCallback(org.apache.avro.ipc.Requestor.Request request,
Callback<T> callback)
Creates a TransceiverCallback.
|
Modifier and Type | Method and Description |
---|---|
<T> void |
GenericRequestor.request(String messageName,
Object request,
Callback<T> callback) |
Modifier and Type | Method and Description |
---|---|
void |
AvroTrace.Callback.getAllSpans(Callback<List<Span>> callback)
Get all spans stored on this host.
|
void |
AvroTrace.Callback.getSpansInRange(long start,
long end,
Callback<List<Span>> callback)
Get spans occuring between start and end.
|
Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.