public class DisruptorQueue extends Object implements IStatefulObject
| Modifier and Type | Class and Description |
|---|---|
static class |
DisruptorQueue.ObjectEventFactory |
| Constructor and Description |
|---|
DisruptorQueue(String queueName,
com.lmax.disruptor.ClaimStrategy claim,
com.lmax.disruptor.WaitStrategy wait) |
| Modifier and Type | Method and Description |
|---|---|
long |
capacity() |
void |
consumeBatch(com.lmax.disruptor.EventHandler<Object> handler) |
void |
consumeBatchWhenAvailable(com.lmax.disruptor.EventHandler<Object> handler) |
void |
consumerStarted() |
String |
getName() |
Object |
getState() |
void |
haltWithInterrupt() |
float |
pctFull() |
long |
population() |
void |
publish(Object obj) |
void |
publish(Object obj,
boolean block) |
long |
readPos() |
void |
tryPublish(Object obj) |
long |
writePos() |
public DisruptorQueue(String queueName, com.lmax.disruptor.ClaimStrategy claim, com.lmax.disruptor.WaitStrategy wait)
public String getName()
public void consumeBatch(com.lmax.disruptor.EventHandler<Object> handler)
public void haltWithInterrupt()
public void consumeBatchWhenAvailable(com.lmax.disruptor.EventHandler<Object> handler)
public void publish(Object obj)
public void tryPublish(Object obj) throws com.lmax.disruptor.InsufficientCapacityException
com.lmax.disruptor.InsufficientCapacityExceptionpublic void publish(Object obj, boolean block) throws com.lmax.disruptor.InsufficientCapacityException
com.lmax.disruptor.InsufficientCapacityExceptionpublic void consumerStarted()
public long population()
public long capacity()
public long writePos()
public long readPos()
public float pctFull()
public Object getState()
getState in interface IStatefulObjectCopyright © 2015. All rights reserved.