|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.otfeed.protocol.request.AbstractRequest org.otfeed.protocol.request.AbstractSessionRequest org.otfeed.protocol.request.BookStreamExRequest
public final class BookStreamExRequest
Request to receive real time book event stream.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.otfeed.protocol.request.AbstractRequest |
---|
AbstractRequest.JobStatus |
Constructor Summary | |
---|---|
BookStreamExRequest(int requestId,
java.lang.String exchangeCode,
java.lang.String symbolCode,
IDataDelegate<OTBookOrder> orderDelegate,
IDataDelegate<OTBookChange> changeDelegate,
IDataDelegate<OTBookReplace> replaceDelegate,
IDataDelegate<OTBookCancel> cancelDelegate,
IDataDelegate<OTBookPurge> purgeDelegate,
IDataDelegate<OTBookExecute> executeDelegate,
IDataDelegate<OTBookDelete> deleteDelegate,
IDataDelegate<OTBookPriceLevel> priceLevelDelegate,
ICompletionDelegate completionDelegate)
|
Method Summary | |
---|---|
void |
fireCompleted(OTError error)
Internal method: used to wake up threads sleeping in waitForCompletion() . |
CommandEnum |
getCancelCommand()
Returns cancel command type. |
OTError |
getError()
|
java.lang.String |
getExchangeCode()
|
java.lang.String |
getSymbolCode()
|
AbstractRequest.JobStatus |
handleMessage(Header header,
java.nio.ByteBuffer in)
Abstract method to handle response message. |
boolean |
isCompleted()
|
void |
waitForCompletion()
Convenience method: blocks calling thread until request finishes. |
boolean |
waitForCompletion(long millis)
Convenience method: blocks calling thread until request finishes, or the specified number of milliseconds elapses. |
void |
writeRequest(java.nio.ByteBuffer out)
Writes out the request header and session string. |
Methods inherited from class org.otfeed.protocol.request.AbstractSessionRequest |
---|
getSessionId, setSessionId |
Methods inherited from class org.otfeed.protocol.request.AbstractRequest |
---|
getCommand, getRequestId, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public BookStreamExRequest(int requestId, java.lang.String exchangeCode, java.lang.String symbolCode, IDataDelegate<OTBookOrder> orderDelegate, IDataDelegate<OTBookChange> changeDelegate, IDataDelegate<OTBookReplace> replaceDelegate, IDataDelegate<OTBookCancel> cancelDelegate, IDataDelegate<OTBookPurge> purgeDelegate, IDataDelegate<OTBookExecute> executeDelegate, IDataDelegate<OTBookDelete> deleteDelegate, IDataDelegate<OTBookPriceLevel> priceLevelDelegate, ICompletionDelegate completionDelegate)
Method Detail |
---|
public java.lang.String getExchangeCode()
public java.lang.String getSymbolCode()
public void writeRequest(java.nio.ByteBuffer out)
AbstractSessionRequest
writeRequest
in class AbstractSessionRequest
out
- output buffer.public AbstractRequest.JobStatus handleMessage(Header header, java.nio.ByteBuffer in)
AbstractRequest
handleMessage
in class AbstractRequest
header
- parsed response header.in
- input buffer with the rest of the
data (after header has been parsed).public final CommandEnum getCancelCommand()
AbstractSessionRequest
CancelRequest
to the server. Such requests must override this method
to return the cancel command type.
getCancelCommand
in class AbstractSessionRequest
public final OTError getError()
public final void fireCompleted(OTError error)
waitForCompletion()
.
public final boolean isCompleted()
public final boolean waitForCompletion(long millis)
millis
- how long to wait for completion.public final void waitForCompletion()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |