|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.devexperts.qd.qtp.AbstractMessageVisitor
public abstract class AbstractMessageVisitor
This class collapses various visitXXXData and visitXXXSubscription methods of
MessageVisitor
interface into just two methods:
visitData(com.devexperts.qd.DataProvider, com.devexperts.qd.qtp.MessageType)
and visitSubscription(com.devexperts.qd.SubscriptionProvider, com.devexperts.qd.qtp.MessageType)
.
All implementations of MessageVisitor
interface shall extends this class.
Constructor Summary | |
---|---|
AbstractMessageVisitor()
|
Method Summary | |
---|---|
abstract boolean |
visitData(DataProvider provider,
MessageType message)
This method consumes available data for data message from the given data provider. |
void |
visitDescribeProtocol(ProtocolDescriptor descriptor)
|
boolean |
visitHistoryAddSubscription(SubscriptionProvider provider)
This method consumes available subscription for MessageType.HISTORY_ADD_SUBSCRIPTION message from
the given subscription provider. |
boolean |
visitHistoryData(DataProvider provider)
This method consumes available data for MessageType.HISTORY_DATA message from
the given data provider. |
boolean |
visitHistoryRemoveSubscription(SubscriptionProvider provider)
This method consumes available subscription for MessageType.HISTORY_REMOVE_SUBSCRIPTION message from
the given subscription provider. |
boolean |
visitOtherMessage(int messageType,
byte[] messageBytes,
int offset,
int length)
This implementation simply skips all unknown messages. |
boolean |
visitStreamAddSubscription(SubscriptionProvider provider)
This method consumes available subscription for MessageType.STREAM_ADD_SUBSCRIPTION message from
the given subscription provider. |
boolean |
visitStreamData(DataProvider provider)
This method consumes available data for MessageType.STREAM_DATA message from
the given data provider. |
boolean |
visitStreamRemoveSubscription(SubscriptionProvider provider)
This method consumes available subscription for MessageType.STREAM_REMOVE_SUBSCRIPTION message from
the given subscription provider. |
abstract boolean |
visitSubscription(SubscriptionProvider provider,
MessageType message)
This method consumes available subscription for subscription message from the given subscription provider. |
boolean |
visitTickerAddSubscription(SubscriptionProvider provider)
This method consumes available subscription for MessageType.TICKER_ADD_SUBSCRIPTION message from
the given subscription provider. |
boolean |
visitTickerData(DataProvider provider)
This method consumes available data for MessageType.TICKER_DATA message from
the given data provider. |
boolean |
visitTickerRemoveSubscription(SubscriptionProvider provider)
This method consumes available subscription for MessageType.TICKER_REMOVE_SUBSCRIPTION message from
the given subscription provider. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AbstractMessageVisitor()
Method Detail |
---|
public void visitDescribeProtocol(ProtocolDescriptor descriptor)
visitDescribeProtocol
in interface MessageVisitor
public abstract boolean visitData(DataProvider provider, MessageType message)
visitData
in interface MessageVisitor
false
if it had retrieved all available data and no data left,
true
if more data remains to be consumedpublic abstract boolean visitSubscription(SubscriptionProvider provider, MessageType message)
visitSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic final boolean visitTickerData(DataProvider provider)
MessageVisitor
MessageType.TICKER_DATA
message from
the given data provider.
visitTickerData
in interface MessageVisitor
false
if it had retrieved all available data and no data left,
true
if more data remains to be consumedpublic final boolean visitTickerAddSubscription(SubscriptionProvider provider)
MessageVisitor
MessageType.TICKER_ADD_SUBSCRIPTION
message from
the given subscription provider.
visitTickerAddSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic final boolean visitTickerRemoveSubscription(SubscriptionProvider provider)
MessageVisitor
MessageType.TICKER_REMOVE_SUBSCRIPTION
message from
the given subscription provider.
visitTickerRemoveSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic final boolean visitStreamData(DataProvider provider)
MessageVisitor
MessageType.STREAM_DATA
message from
the given data provider.
visitStreamData
in interface MessageVisitor
false
if it had retrieved all available data and no data left,
true
if more data remains to be consumedpublic final boolean visitStreamAddSubscription(SubscriptionProvider provider)
MessageVisitor
MessageType.STREAM_ADD_SUBSCRIPTION
message from
the given subscription provider.
visitStreamAddSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic final boolean visitStreamRemoveSubscription(SubscriptionProvider provider)
MessageVisitor
MessageType.STREAM_REMOVE_SUBSCRIPTION
message from
the given subscription provider.
visitStreamRemoveSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic final boolean visitHistoryData(DataProvider provider)
MessageVisitor
MessageType.HISTORY_DATA
message from
the given data provider.
visitHistoryData
in interface MessageVisitor
false
if it had retrieved all available data and no data left,
true
if more data remains to be consumedpublic final boolean visitHistoryAddSubscription(SubscriptionProvider provider)
MessageVisitor
MessageType.HISTORY_ADD_SUBSCRIPTION
message from
the given subscription provider.
visitHistoryAddSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic final boolean visitHistoryRemoveSubscription(SubscriptionProvider provider)
MessageVisitor
MessageType.HISTORY_REMOVE_SUBSCRIPTION
message from
the given subscription provider.
visitHistoryRemoveSubscription
in interface MessageVisitor
false
if it had retrieved all available subscription and nothing left,
true
if more subscription remains to be consumedpublic boolean visitOtherMessage(int messageType, byte[] messageBytes, int offset, int length)
visitOtherMessage
in interface MessageVisitor
messageType
- integer number representing a type of the message.messageBytes
- array containing message data.offset
- position of the first byte of message data in messageBytes
array.length
- number of bytes starting from offset in
messageBytes
related to this message.
- Returns:
- true if the whole message was not processed because the visitor is full
and false if the message was successfully processed.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |