|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.devexperts.qd.qtp.MessageConsumerAdapter
public class MessageConsumerAdapter
Implementation of MessageConsumer that does nothing. Error methods in this
implementation write message to the log file with Logging.error(java.lang.String)
and
all functional methods skip incoming data and call handleUnknownMessage(int)
.
Field Summary |
---|
Constructor Summary | |
---|---|
MessageConsumerAdapter()
|
Method Summary | |
---|---|
java.lang.String |
getSymbol(char[] chars,
int offset,
int length)
Returns symbol used for specified characters or null if not found. |
void |
handleCorruptedMessage(int message_type)
|
void |
handleCorruptedStream()
|
void |
handleUnknownMessage(int message_type)
|
protected void |
processData(DataIterator iterator,
MessageType message)
|
void |
processDescribeProtocol(ProtocolDescriptor desc)
Processes incoming protocol descriptor and returns true if this message
consumer understands the protocol that remote peer intends to use. |
void |
processHistoryAddSubscription(SubscriptionIterator iterator)
This implementation calls processSubscription(iterator, MessageType.HISTORY_ADD_SUBSCRIPTION) . |
void |
processHistoryData(DataIterator iterator)
This implementation calls processData(iterator, MessageType.HISTORY_DATA) . |
void |
processHistoryRemoveSubscription(SubscriptionIterator iterator)
This implementation calls processSubscription(iterator, MessageType.HISTORY_REMOVE_SUBSCRIPTION) . |
void |
processOtherMessage(int message_type,
byte[] bytes,
int ofs,
int len)
This implementation calls handleUnknownMessage(message_type) . |
void |
processStreamAddSubscription(SubscriptionIterator iterator)
This implementation calls processSubscription(iterator, MessageType.STREAM_ADD_SUBSCRIPTION) . |
void |
processStreamData(DataIterator iterator)
This implementation calls processData(iterator, MessageType.STREAM_DATA) . |
void |
processStreamRemoveSubscription(SubscriptionIterator iterator)
This implementation calls processSubscription(iterator, MessageType.STREAM_REMOVE_SUBSCRIPTION) . |
protected void |
processSubscription(SubscriptionIterator iterator,
MessageType message)
|
void |
processTickerAddSubscription(SubscriptionIterator iterator)
This implementation calls processSubscription(iterator, MessageType.TICKER_ADD_SUBSCRIPTION) . |
void |
processTickerData(DataIterator iterator)
This implementation calls processData(iterator, MessageType.TICKER_DATA) . |
void |
processTickerRemoveSubscription(SubscriptionIterator iterator)
This implementation calls processSubscription(iterator, MessageType.TICKER_REMOVE_SUBSCRIPTION) . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public MessageConsumerAdapter()
Method Detail |
---|
public java.lang.String getSymbol(char[] chars, int offset, int length)
null
if not found.
public void handleCorruptedStream()
handleCorruptedStream
in interface MessageConsumer
public void handleCorruptedMessage(int message_type)
handleCorruptedMessage
in interface MessageConsumer
public void handleUnknownMessage(int message_type)
handleUnknownMessage
in interface MessageConsumer
public void processDescribeProtocol(ProtocolDescriptor desc)
MessageConsumer
true
if this message
consumer understands the protocol that remote peer intends to use.
processDescribeProtocol
in interface MessageConsumer
protected void processData(DataIterator iterator, MessageType message)
protected void processSubscription(SubscriptionIterator iterator, MessageType message)
public void processTickerData(DataIterator iterator)
processData(iterator, MessageType.TICKER_DATA)
.
processTickerData
in interface MessageConsumer
public void processTickerAddSubscription(SubscriptionIterator iterator)
processSubscription(iterator, MessageType.TICKER_ADD_SUBSCRIPTION)
.
processTickerAddSubscription
in interface MessageConsumer
public void processTickerRemoveSubscription(SubscriptionIterator iterator)
processSubscription(iterator, MessageType.TICKER_REMOVE_SUBSCRIPTION)
.
processTickerRemoveSubscription
in interface MessageConsumer
public void processStreamData(DataIterator iterator)
processData(iterator, MessageType.STREAM_DATA)
.
processStreamData
in interface MessageConsumer
public void processStreamAddSubscription(SubscriptionIterator iterator)
processSubscription(iterator, MessageType.STREAM_ADD_SUBSCRIPTION)
.
processStreamAddSubscription
in interface MessageConsumer
public void processStreamRemoveSubscription(SubscriptionIterator iterator)
processSubscription(iterator, MessageType.STREAM_REMOVE_SUBSCRIPTION)
.
processStreamRemoveSubscription
in interface MessageConsumer
public void processHistoryData(DataIterator iterator)
processData(iterator, MessageType.HISTORY_DATA)
.
processHistoryData
in interface MessageConsumer
public void processHistoryAddSubscription(SubscriptionIterator iterator)
processSubscription(iterator, MessageType.HISTORY_ADD_SUBSCRIPTION)
.
processHistoryAddSubscription
in interface MessageConsumer
public void processHistoryRemoveSubscription(SubscriptionIterator iterator)
processSubscription(iterator, MessageType.HISTORY_REMOVE_SUBSCRIPTION)
.
processHistoryRemoveSubscription
in interface MessageConsumer
public void processOtherMessage(int message_type, byte[] bytes, int ofs, int len)
handleUnknownMessage(message_type)
.
processOtherMessage
in interface MessageConsumer
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |