biz.onixs.fix.engine
Interface OutQueue

All Known Implementing Classes:

AbstractOutQueue, MemoryOutQueue, StorageOutQueue

public interface OutQueue

Method Summary

void	clear()
void	drainTo(List<NumberedRawMsg> msgs, int amount, long timeout)
long	getAvailable()
long	getCount()
NumberedRawMsgPool	getPool()
int	getQueueBufSize()
SessionStorage	getStorage()
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	setPool(NumberedRawMsgPool rawMsgPool)
void	setQueueBufSize(int queueBufSize)
void	setStorage(SessionStorage storage)

Method Detail

put

void put(NumberedRawMsg msg)

put

void put(List<NumberedRawMsg> msgs)

offer

boolean offer(NumberedRawMsg msg)

offer

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

offer

boolean offer(List<NumberedRawMsg> msgs)

poll

NumberedRawMsg poll(long timeout)
                    throws InterruptedException,
                           TimeoutException

Throws:

InterruptedException

TimeoutException

drainTo

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

Throws:

InterruptedException

TimeoutException

clear

void clear()

getCount

long getCount()

peek

NumberedRawMsg peek()

getTotalSize

long getTotalSize()

getAvailable

long getAvailable()

getStorage

SessionStorage getStorage()

setStorage

void setStorage(SessionStorage storage)

getQueueBufSize

int getQueueBufSize()

setQueueBufSize

void setQueueBufSize(int queueBufSize)

setPool

void setPool(NumberedRawMsgPool rawMsgPool)

getPool

NumberedRawMsgPool getPool()