com.epam.mdp.full.coders
Class BOVESPAFASTDecoder

java.lang.Object
  com.epam.mdp.full.coders.AbstractFASTDecoder
      com.epam.mdp.full.coders.BOVESPAFASTDecoder

All Implemented Interfaces:

Coder, Decoder

public class BOVESPAFASTDecoder
extends com.epam.mdp.full.coders.AbstractFASTDecoder

Creates BOVESPA fast encoder.

Field Summary

Fields inherited from class com.epam.mdp.full.coders.AbstractFASTDecoder

a, b

Fields inherited from interface com.epam.mdp.full.coders.Coder

PACKET_LENGTH_LIMITATION

Constructor Summary

BOVESPAFASTDecoder(Context context)
Creates the FASTDecoder .

Method Summary

protected void	decodeFromMessage(byte[] message, int length, DistributionStrategy strategy, com.epam.mdp.full.coders.stream.SeqNumHelper seqListener)
protected void	decodeFromStream(java.io.InputStream stream, DistributionStrategy strategy, com.epam.mdp.full.coders.stream.SeqNumHelper seqListener) Decodes from stream data.

Methods inherited from class com.epam.mdp.full.coders.AbstractFASTDecoder

a, a, a, decode, decodeBinary, getCountOfMessages, main, resetContext, setContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BOVESPAFASTDecoder

public BOVESPAFASTDecoder(Context context)

Creates the FASTDecoder .

Method Detail

decodeFromStream

protected void decodeFromStream(java.io.InputStream stream,
                                DistributionStrategy strategy,
                                com.epam.mdp.full.coders.stream.SeqNumHelper seqListener)

Decodes from stream data.

Specified by:

decodeFromStream in interface Decoder

Overrides:

decodeFromStream in class com.epam.mdp.full.coders.AbstractFASTDecoder

Parameters:

stream - the stream

strategy - the strategy

decodeFromMessage

protected void decodeFromMessage(byte[] message,
                                 int length,
                                 DistributionStrategy strategy,
                                 com.epam.mdp.full.coders.stream.SeqNumHelper seqListener)