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,
long timeout) |
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, long timeout)
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.InsufficientCapacityException
public void publish(Object obj, boolean block) throws com.lmax.disruptor.InsufficientCapacityException
com.lmax.disruptor.InsufficientCapacityException
public void consumerStarted()
public long population()
public long capacity()
public long writePos()
public long readPos()
public float pctFull()
public Object getState()
getState
in interface IStatefulObject
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.