backtype.storm.spout

Class KestrelThriftClient

java.lang.Object

backtype.storm.spout.KestrelThriftClient

All Implemented Interfaces:

Kestrel.Iface

public class KestrelThriftClient
extends Object
implements Kestrel.Iface

Constructor Summary

Constructors

Constructor and Description
KestrelThriftClient(String hostname, int port)

Method Summary

Methods

Modifier and Type	Method and Description
int	abort(String queue_name, Set<Long> ids)
void	close()
int	confirm(String queue_name, Set<Long> ids)
void	delete_queue(String queue_name)
void	flush_all_queues()
void	flush_queue(String queue_name)
String	get_version()
List<Item>	get(String queue_name, int max_items, int timeout_msec, int auto_abort_msec)
QueueInfo	peek(String queue_name)
int	put(String queue_name, List<ByteBuffer> items, int expiration_msec)
void	put(String queue_name, String item, int expiration_msec)

Methods inherited from class java.lang.Object

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

Constructor Detail

KestrelThriftClient

public KestrelThriftClient(String hostname,
                   int port)
                    throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

Method Detail

close

public void close()

peek

public QueueInfo peek(String queue_name)
               throws org.apache.thrift7.TException

Specified by:

peek in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

delete_queue

public void delete_queue(String queue_name)
                  throws org.apache.thrift7.TException

Specified by:

delete_queue in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

get_version

public String get_version()
                   throws org.apache.thrift7.TException

Specified by:

get_version in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

put

public int put(String queue_name,
      List<ByteBuffer> items,
      int expiration_msec)
        throws org.apache.thrift7.TException

Specified by:

put in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

put

public void put(String queue_name,
       String item,
       int expiration_msec)
         throws org.apache.thrift7.TException

Throws:

org.apache.thrift7.TException

get

public List<Item> get(String queue_name,
             int max_items,
             int timeout_msec,
             int auto_abort_msec)
               throws org.apache.thrift7.TException

Specified by:

get in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

confirm

public int confirm(String queue_name,
          Set<Long> ids)
            throws org.apache.thrift7.TException

Specified by:

confirm in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

abort

public int abort(String queue_name,
        Set<Long> ids)
          throws org.apache.thrift7.TException

Specified by:

abort in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

flush_queue

public void flush_queue(String queue_name)
                 throws org.apache.thrift7.TException

Specified by:

flush_queue in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException

flush_all_queues

public void flush_all_queues()
                      throws org.apache.thrift7.TException

Specified by:

flush_all_queues in interface Kestrel.Iface

Throws:

org.apache.thrift7.TException