com.epam.cmemdp.channel
Class Corridor

java.lang.Object
  com.epam.cmemdp.channel.Corridor

public class Corridor
extends java.lang.Object

Field Summary

static boolean	DEBUG_ENABLED
protected static Log	log

Constructor Summary

Corridor(java.lang.String securityDescription, int corridorQueueSize, OverflowListener listener)

Method Summary

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(java.lang.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(java.lang.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 java.lang.InterruptedException

Throws:

java.lang.InterruptedException

unlock

public void unlock()
            throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

setChannelID

public void setChannelID(java.lang.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)