com.devexperts.qd.qtp
Interface MessageConsumer

All Known Implementing Classes:
AgentAdapter, DistributorAdapter, MessageAdapter, MessageConsumerAdapter

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

handleCorruptedStream

void handleCorruptedStream()

handleCorruptedMessage

void handleCorruptedMessage(int message_type)

handleUnknownMessage

void handleUnknownMessage(int message_type)

processDescribeProtocol

void processDescribeProtocol(ProtocolDescriptor desc)
Processes incoming protocol descriptor and returns true if this message consumer understands the protocol that remote peer intends to use.


processTickerData

void processTickerData(DataIterator iterator)

processTickerAddSubscription

void processTickerAddSubscription(SubscriptionIterator iterator)

processTickerRemoveSubscription

void processTickerRemoveSubscription(SubscriptionIterator iterator)

processStreamData

void processStreamData(DataIterator iterator)

processStreamAddSubscription

void processStreamAddSubscription(SubscriptionIterator iterator)

processStreamRemoveSubscription

void processStreamRemoveSubscription(SubscriptionIterator iterator)

processHistoryData

void processHistoryData(DataIterator iterator)

processHistoryAddSubscription

void processHistoryAddSubscription(SubscriptionIterator iterator)

processHistoryRemoveSubscription

void processHistoryRemoveSubscription(SubscriptionIterator iterator)

processOtherMessage

void processOtherMessage(int message_type,
                         byte[] bytes,
                         int ofs,
                         int len)