|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageConsumer
The MessageConsumer
processes incoming QTP messages.
It shall be implemented by an agent of some entity to be used by standard QTP connectors.
Its methods are invoked by incoming events, usually from threads allocated internally
by used QTP connector.
Implementations of this inteface shall extend MessageConsumerAdapter
.
Method Summary | |
---|---|
void |
handleCorruptedMessage(int message_type)
|
void |
handleCorruptedStream()
|
void |
handleUnknownMessage(int message_type)
|
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)
|
void |
processHistoryData(DataIterator iterator)
|
void |
processHistoryRemoveSubscription(SubscriptionIterator iterator)
|
void |
processOtherMessage(int message_type,
byte[] bytes,
int ofs,
int len)
|
void |
processStreamAddSubscription(SubscriptionIterator iterator)
|
void |
processStreamData(DataIterator iterator)
|
void |
processStreamRemoveSubscription(SubscriptionIterator iterator)
|
void |
processTickerAddSubscription(SubscriptionIterator iterator)
|
void |
processTickerData(DataIterator iterator)
|
void |
processTickerRemoveSubscription(SubscriptionIterator iterator)
|
Method Detail |
---|
void handleCorruptedStream()
void handleCorruptedMessage(int message_type)
void handleUnknownMessage(int message_type)
void processDescribeProtocol(ProtocolDescriptor desc)
true
if this message
consumer understands the protocol that remote peer intends to use.
void processTickerData(DataIterator iterator)
void processTickerAddSubscription(SubscriptionIterator iterator)
void processTickerRemoveSubscription(SubscriptionIterator iterator)
void processStreamData(DataIterator iterator)
void processStreamAddSubscription(SubscriptionIterator iterator)
void processStreamRemoveSubscription(SubscriptionIterator iterator)
void processHistoryData(DataIterator iterator)
void processHistoryAddSubscription(SubscriptionIterator iterator)
void processHistoryRemoveSubscription(SubscriptionIterator iterator)
void processOtherMessage(int message_type, byte[] bytes, int ofs, int len)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |