public abstract class TAsyncClient
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected TAsyncMethodCall |
___currentMethod |
protected TAsyncClientManager |
___manager |
protected TProtocolFactory |
___protocolFactory |
protected TNonblockingTransport |
___transport |
Constructor and Description |
---|
TAsyncClient(TProtocolFactory protocolFactory,
TAsyncClientManager manager,
TNonblockingTransport transport) |
TAsyncClient(TProtocolFactory protocolFactory,
TAsyncClientManager manager,
TNonblockingTransport transport,
long timeout) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkReady() |
java.lang.Exception |
getError()
Get the client's error - returns null if no error
|
TProtocolFactory |
getProtocolFactory() |
long |
getTimeout() |
boolean |
hasError()
Is the client in an error state?
|
boolean |
hasTimeout() |
protected void |
onComplete()
Called by delegate method when finished
|
protected void |
onError(java.lang.Exception exception)
Called by delegate method on error
|
void |
setTimeout(long timeout) |
protected final TProtocolFactory ___protocolFactory
protected final TNonblockingTransport ___transport
protected final TAsyncClientManager ___manager
protected TAsyncMethodCall ___currentMethod
public TAsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager manager, TNonblockingTransport transport)
public TAsyncClient(TProtocolFactory protocolFactory, TAsyncClientManager manager, TNonblockingTransport transport, long timeout)
public TProtocolFactory getProtocolFactory()
public long getTimeout()
public boolean hasTimeout()
public void setTimeout(long timeout)
public boolean hasError()
public java.lang.Exception getError()
protected void checkReady()
protected void onComplete()
protected void onError(java.lang.Exception exception)