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

Modifier and Type	Method and Description
void	handleCorruptedMessage(int messageTypeId)
void	handleCorruptedStream()
void	handleUnknownMessage(int messageTypeId)
void	processDescribeProtocol(ProtocolDescriptor desc, boolean logging) Processes incoming protocol descriptor and returns true if this message consumer understands the protocol that remote peer intends to use.
void	processHeartbeat(HeartbeatPayload heartbeatPayload)
void	processHistoryAddSubscription(SubscriptionIterator iterator)
void	processHistoryData(DataIterator iterator)
void	processHistoryRemoveSubscription(SubscriptionIterator iterator)
void	processOtherMessage(int messageTypeId, byte[] bytes, int ofs, int len) Deprecated. Override and use MessageConsumerAdapter.processOtherMessage(int, BufferedInput, int)
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 messageTypeId)

handleUnknownMessage

void handleUnknownMessage(int messageTypeId)

processDescribeProtocol

void processDescribeProtocol(ProtocolDescriptor desc,
                             boolean logging)

Processes incoming protocol descriptor and returns true if this message consumer understands the protocol that remote peer intends to use.

processHeartbeat

void processHeartbeat(HeartbeatPayload heartbeatPayload)

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 messageTypeId,
                         byte[] bytes,
                         int ofs,
                         int len)

Deprecated. Override and use MessageConsumerAdapter.processOtherMessage(int, BufferedInput, int)