com.epam.cmefast.channel

Class Corridor

java.lang.Object

com.epam.cmefast.channel.Corridor

public class Corridor
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DEBUG_ENABLED
protected static Log	log

Constructor Summary

Constructors

Constructor and Description
Corridor(String securityDescription, int corridorQueueSize, OverflowListener listener)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
int	getEntriesCount()
int	getEventsCount()
boolean	haveEvents()
boolean	haveIncrements()
boolean	haveOtherMessages()
boolean	haveSnapshot()
boolean	isProcessing()
void	lock()
GroupEntry	popEntry()
InstrumentEvent	popEvent()
FIXFieldList	popOtherMessage()
FIXFieldList	popSnapshot()
void	pushEvent(InstrumentEvent event)
void	pushGroupEntry(GroupEntry entry)
void	resetOtherMessage(FIXFieldList otherMessage)
void	resetSnapshot(FIXFieldList snapshot)
void	setChannelID(String channelID)
void	startProcessing()
void	stopProcessing()
void	unlock()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final Log log

DEBUG_ENABLED

public static final boolean DEBUG_ENABLED

Constructor Detail

Corridor

public Corridor(String securityDescription,
        int corridorQueueSize,
        OverflowListener listener)

Method Detail

stopProcessing

public void stopProcessing()

startProcessing

public void startProcessing()

isProcessing

public boolean isProcessing()

pushGroupEntry

public void pushGroupEntry(GroupEntry entry)

getEntriesCount

public int getEntriesCount()

haveIncrements

public boolean haveIncrements()

popEntry

public GroupEntry popEntry()

clear

public void clear()

lock

public void lock()
          throws InterruptedException

Throws:

InterruptedException

unlock

public void unlock()
            throws InterruptedException

Throws:

InterruptedException

setChannelID

public void setChannelID(String channelID)

resetOtherMessage

public void resetOtherMessage(FIXFieldList otherMessage)

haveOtherMessages

public boolean haveOtherMessages()

popOtherMessage

public FIXFieldList popOtherMessage()

resetSnapshot

public void resetSnapshot(FIXFieldList snapshot)

haveSnapshot

public boolean haveSnapshot()

popSnapshot

public FIXFieldList popSnapshot()

getEventsCount

public int getEventsCount()

haveEvents

public boolean haveEvents()

popEvent

public InstrumentEvent popEvent()

pushEvent

public void pushEvent(InstrumentEvent event)