MessageConsumerAdapter (QD Core API 3.346)

java.lang.Object
- com.devexperts.qd.qtp.MessageConsumerAdapter

All Implemented Interfaces:

MessageConsumer, SymbolCodec.Resolver

Direct Known Subclasses:

MessageAdapter
```
public class MessageConsumerAdapter
extends Object
implements MessageConsumer, SymbolCodec.Resolver
```
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

Fields
Modifier and Type	Field and Description
`static int`	`MAX_SUPPORTED_MESSAGE_TYPE`
`static int`	`MESSAGE_DESCRIBE_PROTOCOL`
`static int`	`MESSAGE_DESCRIBE_RECORDS`
`static int`	`MESSAGE_DESCRIBE_RESERVED`
`static int`	`MESSAGE_GZIP_COMPRESSION` This value is reserved and can not be used as any message type.
`static int`	`MESSAGE_HEARTBEAT`
`static int`	`MESSAGE_HISTORY_ADD_SUBSCRIPTION`
`static int`	`MESSAGE_HISTORY_DATA`
`static int`	`MESSAGE_HISTORY_REMOVE_SUBSCRIPTION`
`static int`	`MESSAGE_PART`
`static int`	`MESSAGE_RAW_DATA`
`static int`	`MESSAGE_RMI_ADVERTISE_SERVICES`
`static int`	`MESSAGE_RMI_CANCEL`
`static int`	`MESSAGE_RMI_DESCRIBE_OPERATION`
`static int`	`MESSAGE_RMI_DESCRIBE_SUBJECT`
`static int`	`MESSAGE_RMI_ERROR`
`static int`	`MESSAGE_RMI_REQUEST`
`static int`	`MESSAGE_RMI_RESPONSE`
`static int`	`MESSAGE_RMI_RESULT`
`static int`	`MESSAGE_STREAM_ADD_SUBSCRIPTION`
`static int`	`MESSAGE_STREAM_DATA`
`static int`	`MESSAGE_STREAM_REMOVE_SUBSCRIPTION`
`static int`	`MESSAGE_TEXT_FORMAT`
`static int`	`MESSAGE_TICKER_ADD_SUBSCRIPTION`
`static int`	`MESSAGE_TICKER_DATA`
`static int`	`MESSAGE_TICKER_REMOVE_SUBSCRIPTION`
`static int`	`MESSAGE_ZIP_COMPRESSION` This value is reserved and can not be used as any message type.

Constructor Summary

Constructors
Constructor and Description

MessageConsumerAdapter()

Constructors
Constructor and Description
`MessageConsumerAdapter()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`String`	`getSymbol(char[] chars, int offset, int length)` Returns symbol used for specified characters or `null` if not found.
`void`	`handleCorruptedMessage(int messageTypeId)`
`void`	`handleCorruptedStream()`
`void`	`handleUnknownMessage(int messageTypeId)`
`protected void`	`processData(DataIterator iterator, MessageType message)`
`void`	`processDescribeProtocol(ProtocolDescriptor desc, boolean logDescriptor)` 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)` 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 messageTypeId, com.devexperts.io.BufferedInput data, int len)`
`void`	`processOtherMessage(int messageTypeId, byte[] bytes, int ofs, int len)` This implementation calls `handleUnknownMessage(message_type)`.
`void`	`processRecordSource(RecordSource source, MessageType message)` This method calls either `processData(DataIterator, MessageType)` or `processSubscription(SubscriptionIterator, MessageType)` depending on message.
`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)`.
`void`	`processTimeProgressReport(long timeMillis)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - MESSAGE_HEARTBEAT
```
public static final int MESSAGE_HEARTBEAT
```
    See Also:
    
    Constant Field Values
  - MESSAGE_DESCRIBE_PROTOCOL
```
public static final int MESSAGE_DESCRIBE_PROTOCOL
```
    See Also:
    
    Constant Field Values
  - MESSAGE_DESCRIBE_RECORDS
```
public static final int MESSAGE_DESCRIBE_RECORDS
```
    See Also:
    
    Constant Field Values
  - MESSAGE_DESCRIBE_RESERVED
```
public static final int MESSAGE_DESCRIBE_RESERVED
```
    See Also:
    
    Constant Field Values
  - MESSAGE_PART
```
public static final int MESSAGE_PART
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RAW_DATA
```
public static final int MESSAGE_RAW_DATA
```
    See Also:
    
    Constant Field Values
  - MESSAGE_TICKER_DATA
```
public static final int MESSAGE_TICKER_DATA
```
    See Also:
    
    Constant Field Values
  - MESSAGE_TICKER_ADD_SUBSCRIPTION
```
public static final int MESSAGE_TICKER_ADD_SUBSCRIPTION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_TICKER_REMOVE_SUBSCRIPTION
```
public static final int MESSAGE_TICKER_REMOVE_SUBSCRIPTION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_STREAM_DATA
```
public static final int MESSAGE_STREAM_DATA
```
    See Also:
    
    Constant Field Values
  - MESSAGE_STREAM_ADD_SUBSCRIPTION
```
public static final int MESSAGE_STREAM_ADD_SUBSCRIPTION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_STREAM_REMOVE_SUBSCRIPTION
```
public static final int MESSAGE_STREAM_REMOVE_SUBSCRIPTION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_HISTORY_DATA
```
public static final int MESSAGE_HISTORY_DATA
```
    See Also:
    
    Constant Field Values
  - MESSAGE_HISTORY_ADD_SUBSCRIPTION
```
public static final int MESSAGE_HISTORY_ADD_SUBSCRIPTION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_HISTORY_REMOVE_SUBSCRIPTION
```
public static final int MESSAGE_HISTORY_REMOVE_SUBSCRIPTION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_ADVERTISE_SERVICES
```
public static final int MESSAGE_RMI_ADVERTISE_SERVICES
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_DESCRIBE_SUBJECT
```
public static final int MESSAGE_RMI_DESCRIBE_SUBJECT
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_DESCRIBE_OPERATION
```
public static final int MESSAGE_RMI_DESCRIBE_OPERATION
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_REQUEST
```
public static final int MESSAGE_RMI_REQUEST
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_CANCEL
```
public static final int MESSAGE_RMI_CANCEL
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_RESULT
```
public static final int MESSAGE_RMI_RESULT
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_ERROR
```
public static final int MESSAGE_RMI_ERROR
```
    See Also:
    
    Constant Field Values
  - MESSAGE_RMI_RESPONSE
```
public static final int MESSAGE_RMI_RESPONSE
```
    See Also:
    
    Constant Field Values
  - MAX_SUPPORTED_MESSAGE_TYPE
```
public static final int MAX_SUPPORTED_MESSAGE_TYPE
```
    See Also:
    
    Constant Field Values
  - MESSAGE_TEXT_FORMAT
```
public static final int MESSAGE_TEXT_FORMAT
```
    See Also:
    
    Constant Field Values
  - MESSAGE_ZIP_COMPRESSION
```
public static final int MESSAGE_ZIP_COMPRESSION
```
    This value is reserved and can not be used as any message type. It is the second byte of zip file compression.
    
    See Also:
    
    Constant Field Values
  - MESSAGE_GZIP_COMPRESSION
```
public static final int MESSAGE_GZIP_COMPRESSION
```
    This value is reserved and can not be used as any message type. It is the second byte of gzip file compression.
    
    See Also:
    
    Constant Field Values
- Constructor Detail
  - MessageConsumerAdapter
```
public MessageConsumerAdapter()
```
- Method Detail
  - getSymbol
```
public String getSymbol(char[] chars,
                        int offset,
                        int length)
```
    Returns symbol used for specified characters or null if not found.
    
    Specified by:
    
    getSymbol in interface SymbolCodec.Resolver
  - handleCorruptedStream
```
public void handleCorruptedStream()
```
    Specified by:
    
    handleCorruptedStream in interface MessageConsumer
  - handleCorruptedMessage
```
public void handleCorruptedMessage(int messageTypeId)
```
    Specified by:
    
    handleCorruptedMessage in interface MessageConsumer
  - handleUnknownMessage
```
public void handleUnknownMessage(int messageTypeId)
```
    Specified by:
    
    handleUnknownMessage in interface MessageConsumer
  - processDescribeProtocol
```
public void processDescribeProtocol(ProtocolDescriptor desc,
                                    boolean logDescriptor)
```
    Description copied from interface: MessageConsumer
    
    Processes incoming protocol descriptor and returns true if this message consumer understands the protocol that remote peer intends to use.
    
    Specified by:
    
    processDescribeProtocol in interface MessageConsumer
  - processHeartbeat
```
public void processHeartbeat(HeartbeatPayload heartbeatPayload)
```
    Specified by:
    
    processHeartbeat in interface MessageConsumer
  - processTimeProgressReport
```
public void processTimeProgressReport(long timeMillis)
```
  - processRecordSource
```
public final void processRecordSource(RecordSource source,
                                      MessageType message)
```
    This method calls either processData(DataIterator, MessageType) or processSubscription(SubscriptionIterator, MessageType) depending on message. When message is MessageType.RAW_DATA and this class does not implement RawDataConsumer, then processData(DataIterator, MessageType) for ticket, stream, and history message types is invoked.
  - processData
```
protected void processData(DataIterator iterator,
                           MessageType message)
```
  - processSubscription
```
protected void processSubscription(SubscriptionIterator iterator,
                                   MessageType message)
```
  - processTickerData
```
public void processTickerData(DataIterator iterator)
```
    This implementation calls processData(iterator, MessageType.TICKER_DATA).
    
    Specified by:
    
    processTickerData in interface MessageConsumer
  - processTickerAddSubscription
```
public void processTickerAddSubscription(SubscriptionIterator iterator)
```
    This implementation calls processSubscription(iterator, MessageType.TICKER_ADD_SUBSCRIPTION).
    
    Specified by:
    
    processTickerAddSubscription in interface MessageConsumer
  - processTickerRemoveSubscription
```
public void processTickerRemoveSubscription(SubscriptionIterator iterator)
```
    This implementation calls processSubscription(iterator, MessageType.TICKER_REMOVE_SUBSCRIPTION).
    
    Specified by:
    
    processTickerRemoveSubscription in interface MessageConsumer
  - processStreamData
```
public void processStreamData(DataIterator iterator)
```
    This implementation calls processData(iterator, MessageType.STREAM_DATA).
    
    Specified by:
    
    processStreamData in interface MessageConsumer
  - processStreamAddSubscription
```
public void processStreamAddSubscription(SubscriptionIterator iterator)
```
    This implementation calls processSubscription(iterator, MessageType.STREAM_ADD_SUBSCRIPTION).
    
    Specified by:
    
    processStreamAddSubscription in interface MessageConsumer
  - processStreamRemoveSubscription
```
public void processStreamRemoveSubscription(SubscriptionIterator iterator)
```
    This implementation calls processSubscription(iterator, MessageType.STREAM_REMOVE_SUBSCRIPTION).
    
    Specified by:
    
    processStreamRemoveSubscription in interface MessageConsumer
  - processHistoryData
```
public void processHistoryData(DataIterator iterator)
```
    This implementation calls processData(iterator, MessageType.HISTORY_DATA).
    
    Specified by:
    
    processHistoryData in interface MessageConsumer
  - processHistoryAddSubscription
```
public void processHistoryAddSubscription(SubscriptionIterator iterator)
```
    This implementation calls processSubscription(iterator, MessageType.HISTORY_ADD_SUBSCRIPTION).
    
    Specified by:
    
    processHistoryAddSubscription in interface MessageConsumer
  - processHistoryRemoveSubscription
```
public void processHistoryRemoveSubscription(SubscriptionIterator iterator)
```
    This implementation calls processSubscription(iterator, MessageType.HISTORY_REMOVE_SUBSCRIPTION).
    
    Specified by:
    
    processHistoryRemoveSubscription in interface MessageConsumer
  - processOtherMessage
```
public final void processOtherMessage(int messageTypeId,
                                      byte[] bytes,
                                      int ofs,
                                      int len)
```
    This implementation calls handleUnknownMessage(message_type).
    
    Specified by:
    
    processOtherMessage in interface MessageConsumer
  - processOtherMessage
```
public void processOtherMessage(int messageTypeId,
                                com.devexperts.io.BufferedInput data,
                                int len)
```

Class MessageConsumerAdapter

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

MESSAGE_HEARTBEAT

MESSAGE_DESCRIBE_PROTOCOL

MESSAGE_DESCRIBE_RECORDS

MESSAGE_DESCRIBE_RESERVED

MESSAGE_PART

MESSAGE_RAW_DATA

MESSAGE_TICKER_DATA

MESSAGE_TICKER_ADD_SUBSCRIPTION

MESSAGE_TICKER_REMOVE_SUBSCRIPTION

MESSAGE_STREAM_DATA

MESSAGE_STREAM_ADD_SUBSCRIPTION

MESSAGE_STREAM_REMOVE_SUBSCRIPTION

MESSAGE_HISTORY_DATA

MESSAGE_HISTORY_ADD_SUBSCRIPTION

MESSAGE_HISTORY_REMOVE_SUBSCRIPTION

MESSAGE_RMI_ADVERTISE_SERVICES

MESSAGE_RMI_DESCRIBE_SUBJECT

MESSAGE_RMI_DESCRIBE_OPERATION

MESSAGE_RMI_REQUEST

MESSAGE_RMI_CANCEL

MESSAGE_RMI_RESULT

MESSAGE_RMI_ERROR

MESSAGE_RMI_RESPONSE

MAX_SUPPORTED_MESSAGE_TYPE

MESSAGE_TEXT_FORMAT

MESSAGE_ZIP_COMPRESSION

MESSAGE_GZIP_COMPRESSION

Constructor Detail

MessageConsumerAdapter

Method Detail

getSymbol

handleCorruptedStream

handleCorruptedMessage

handleUnknownMessage

processDescribeProtocol

processHeartbeat

processTimeProgressReport

processRecordSource

processData

processSubscription

processTickerData

processTickerAddSubscription

processTickerRemoveSubscription

processStreamData

processStreamAddSubscription

processStreamRemoveSubscription

processHistoryData

processHistoryAddSubscription

processHistoryRemoveSubscription

processOtherMessage

processOtherMessage