biz.onixs.fix.engine
Class StorageOutQueue

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

All Implemented Interfaces:

OutQueue

public class StorageOutQueue
extends AbstractOutQueue

Field Summary

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

pool, queueBufSize, storage

Constructor Summary

StorageOutQueue()

Method Summary

void	clear()
void	drainTo(List<NumberedRawMsg> msgs, 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)

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

getPool, getQueueBufSize, getStorage, setPool, setQueueBufSize, setStorage

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageOutQueue

public StorageOutQueue()

Method Detail

put

public void put(NumberedRawMsg msg)

put

public void put(List<NumberedRawMsg> msgs)

offer

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

offer

public boolean offer(NumberedRawMsg msg)

getAvailable

public long getAvailable()

drainTo

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

Throws:

InterruptedException

TimeoutException

offer

public boolean offer(List<NumberedRawMsg> msgs)

poll

public NumberedRawMsg poll(long timeout)
                    throws InterruptedException,
                           TimeoutException

Throws:

InterruptedException

TimeoutException

clear

public void clear()

getCount

public long getCount()

peek

public NumberedRawMsg peek()

getTotalSize

public long getTotalSize()