Package deltix.qsrv.hf.blocks

Class SynchronizedMarketMessageQueue

java.lang.Object

deltix.qsrv.hf.blocks.SynchronizedMarketMessageQueue

public class SynchronizedMarketMessageQueue
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
SynchronizedMarketMessageQueue(int size)

Method Summary

Modifier and Type	Method	Description
void	put(deltix.timebase.api.messages.MarketMessage msg)
deltix.timebase.api.messages.MarketMessage	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

SynchronizedMarketMessageQueue

public SynchronizedMarketMessageQueue(int size)

Method Detail

put

public void put(deltix.timebase.api.messages.MarketMessage msg)
         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

take

public deltix.timebase.api.messages.MarketMessage take()
                                                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException