biz.onixs.fix.engine
Class MemoryOutQueue

java.lang.Object
  biz.onixs.fix.engine.AbstractOutQueue
      biz.onixs.fix.engine.MemoryOutQueue

All Implemented Interfaces:

OutQueue

public class MemoryOutQueue
extends AbstractOutQueue

Field Summary

Fields inherited from class biz.onixs.fix.engine.AbstractOutQueue

pool, queueBufSize, storage

Constructor Summary

MemoryOutQueue()

Method Summary

void	clear()
void	drainTo(List<NumberedRawMsg> list, int amount, long timeout)
long	getAvailable()
long	getCount()
long	getTotalSize()
boolean	offer(List<NumberedRawMsg> msgs)
boolean	offer(NumberedRawMsg msg)
boolean	offer(NumberedRawMsg msg, long timeout, TimeUnit unit)
NumberedRawMsg	peek()
NumberedRawMsg	poll(long timeout)
void	put(List<NumberedRawMsg> msgs)
void	put(NumberedRawMsg msg)
void	setQueueBufSize(int queueBufSize)

Methods inherited from class biz.onixs.fix.engine.AbstractOutQueue

getPool, getQueueBufSize, getStorage, setPool, setStorage

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryOutQueue

public MemoryOutQueue()

Method Detail

setQueueBufSize

public void setQueueBufSize(int queueBufSize)

Specified by:

setQueueBufSize in interface OutQueue

Overrides:

setQueueBufSize in class AbstractOutQueue

offer

public boolean offer(NumberedRawMsg msg,
                     long timeout,
                     TimeUnit unit)

put

public void put(List<NumberedRawMsg> msgs)

offer

public boolean offer(List<NumberedRawMsg> msgs)

offer

public boolean offer(NumberedRawMsg msg)

put

public void put(NumberedRawMsg msg)

poll

public NumberedRawMsg poll(long timeout)
                    throws InterruptedException,
                           TimeoutException

Throws:

InterruptedException

TimeoutException

drainTo

public void drainTo(List<NumberedRawMsg> list,
                    int amount,
                    long timeout)
             throws InterruptedException,
                    TimeoutException

Throws:

InterruptedException

TimeoutException

clear

public void clear()

getCount

public long getCount()

getAvailable

public long getAvailable()

peek

public NumberedRawMsg peek()

getTotalSize

public long getTotalSize()