net.lag.kestrel.thrift

Class Kestrel.AsyncClient

java.lang.Object

org.apache.thrift7.async.TAsyncClient

net.lag.kestrel.thrift.Kestrel.AsyncClient

All Implemented Interfaces:

Kestrel.AsyncIface

Enclosing class:

Kestrel

public static class Kestrel.AsyncClient
extends org.apache.thrift7.async.TAsyncClient
implements Kestrel.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Kestrel.AsyncClient.abort_call
static class	Kestrel.AsyncClient.confirm_call
static class	Kestrel.AsyncClient.delete_queue_call
static class	Kestrel.AsyncClient.Factory
static class	Kestrel.AsyncClient.flush_all_queues_call
static class	Kestrel.AsyncClient.flush_queue_call
static class	Kestrel.AsyncClient.get_call
static class	Kestrel.AsyncClient.get_version_call
static class	Kestrel.AsyncClient.peek_call
static class	Kestrel.AsyncClient.put_call

Field Summary

Fields inherited from class org.apache.thrift7.async.TAsyncClient

___currentMethod, ___manager, ___protocolFactory, ___transport

Constructor Summary

Constructors

Constructor and Description
AsyncClient(org.apache.thrift7.protocol.TProtocolFactory protocolFactory, org.apache.thrift7.async.TAsyncClientManager clientManager, org.apache.thrift7.transport.TNonblockingTransport transport)

Method Summary

Modifier and Type	Method and Description
void	abort(String queue_name, Set<Long> ids, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.abort_call> resultHandler)
void	confirm(String queue_name, Set<Long> ids, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.confirm_call> resultHandler)
void	delete_queue(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.delete_queue_call> resultHandler)
void	flush_all_queues(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_all_queues_call> resultHandler)
void	flush_queue(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_queue_call> resultHandler)
void	get_version(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_version_call> resultHandler)
void	get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_call> resultHandler)
void	peek(String queue_name, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.peek_call> resultHandler)
void	put(String queue_name, List<ByteBuffer> items, int expiration_msec, org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.put_call> resultHandler)

Methods inherited from class org.apache.thrift7.async.TAsyncClient

checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncClient

public AsyncClient(org.apache.thrift7.protocol.TProtocolFactory protocolFactory,
                   org.apache.thrift7.async.TAsyncClientManager clientManager,
                   org.apache.thrift7.transport.TNonblockingTransport transport)

Method Detail

put

public void put(String queue_name,
                List<ByteBuffer> items,
                int expiration_msec,
                org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.put_call> resultHandler)
         throws org.apache.thrift7.TException

Specified by:

put in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

get

public void get(String queue_name,
                int max_items,
                int timeout_msec,
                int auto_abort_msec,
                org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_call> resultHandler)
         throws org.apache.thrift7.TException

Specified by:

get in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

confirm

public void confirm(String queue_name,
                    Set<Long> ids,
                    org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.confirm_call> resultHandler)
             throws org.apache.thrift7.TException

Specified by:

confirm in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

abort

public void abort(String queue_name,
                  Set<Long> ids,
                  org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.abort_call> resultHandler)
           throws org.apache.thrift7.TException

Specified by:

abort in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

peek

public void peek(String queue_name,
                 org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.peek_call> resultHandler)
          throws org.apache.thrift7.TException

Specified by:

peek in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

flush_queue

public void flush_queue(String queue_name,
                        org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_queue_call> resultHandler)
                 throws org.apache.thrift7.TException

Specified by:

flush_queue in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

flush_all_queues

public void flush_all_queues(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.flush_all_queues_call> resultHandler)
                      throws org.apache.thrift7.TException

Specified by:

flush_all_queues in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

delete_queue

public void delete_queue(String queue_name,
                         org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.delete_queue_call> resultHandler)
                  throws org.apache.thrift7.TException

Specified by:

delete_queue in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException

get_version

public void get_version(org.apache.thrift7.async.AsyncMethodCallback<Kestrel.AsyncClient.get_version_call> resultHandler)
                 throws org.apache.thrift7.TException

Specified by:

get_version in interface Kestrel.AsyncIface

Throws:

org.apache.thrift7.TException