Package | Description |
---|---|
backtype.storm.spout | |
net.lag.kestrel.thrift |
Modifier and Type | Method and Description |
---|---|
QueueInfo |
KestrelThriftClient.peek(String queue_name) |
Modifier and Type | Method and Description |
---|---|
QueueInfo |
QueueInfo.deepCopy() |
QueueInfo |
Kestrel.peek_result.get_success() |
QueueInfo |
Kestrel.AsyncClient.peek_call.getResult() |
QueueInfo |
Kestrel.Iface.peek(String queue_name) |
QueueInfo |
Kestrel.Client.peek(String queue_name) |
QueueInfo |
Kestrel.Client.recv_peek() |
Modifier and Type | Method and Description |
---|---|
int |
QueueInfo.compareTo(QueueInfo other) |
boolean |
QueueInfo.equals(QueueInfo that) |
void |
Kestrel.peek_result.set_success(QueueInfo success) |
Constructor and Description |
---|
peek_result(QueueInfo success) |
QueueInfo(QueueInfo other)
Performs a deep copy on other.
|