com.bluejeans.common.utils

Class BigQueue<E>

java.lang.Object

com.bluejeans.common.bigqueue.BigQueue

com.bluejeans.common.utils.BigQueue<E>

Type Parameters:

E - the entity type

All Implemented Interfaces:

Closeable, AutoCloseable

public class BigQueue<E>
extends com.bluejeans.common.bigqueue.BigQueue

Big queue extension

Author:

Dinesh Ilindra

Constructor Summary

Constructors

Constructor and Description
BigQueue(String queueDir, String queueName)
BigQueue(String queueDir, String queueName, Class<E> entityType)
BigQueue(String queueDir, String queueName, int pageSize)
BigQueue(String queueDir, String queueName, int pageSize, Class<E> entityType)

Method Summary

Modifier and Type	Method and Description
int	drainTo(Collection<? super E> c, int maxElements)
E	element(byte[] data)
int	peekTo(Collection<? super E> c, int maxElements)
E	pop()
void	push(E element)

Methods inherited from class com.bluejeans.common.bigqueue.BigQueue

applyForEach, close, dequeue, dequeueAsync, dequeueMulti, enqueue, flush, gc, isEmpty, peek, peekAsync, peekMulti, removeAll, size

Methods inherited from class java.lang.Object

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

Constructor Detail

BigQueue

public BigQueue(String queueDir,
                String queueName,
                int pageSize)

BigQueue

public BigQueue(String queueDir,
                String queueName)

BigQueue

public BigQueue(String queueDir,
                String queueName,
                int pageSize,
                Class<E> entityType)

BigQueue

public BigQueue(String queueDir,
                String queueName,
                Class<E> entityType)

Method Detail

push

public void push(E element)

pop

public E pop()

element

public E element(byte[] data)

drainTo

public int drainTo(Collection<? super E> c,
                   int maxElements)

peekTo

public int peekTo(Collection<? super E> c,
                  int maxElements)