org.openfast.examples.util

Class FastMessageReader

java.lang.Object

org.openfast.examples.util.FastMessageReader

public class FastMessageReader
extends Object

An object to decode incoming FAST messages and pas them to a FastMessageConsumer.

Constructor Summary

Constructors

Constructor and Description
FastMessageReader(InputStream input, InputStream templateStream, FastMessageConsumer output) Construct the reader.
FastMessageReader(InputStream input, InputStream templateStream, FastMessageConsumer output, int readOffset) Construct the reader.

Method Summary

Methods

Modifier and Type	Method and Description
void	resetEveryRecord(boolean resetEveryRecord) Reset the decoder on every record.
void	setHead(int count) Limit the number of records to be processed
void	showRawData(boolean flag) Set flag to call the output annotate message with raw data in hex.
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

FastMessageReader

public FastMessageReader(InputStream input,
                 InputStream templateStream,
                 FastMessageConsumer output)

Construct the reader.

Parameters:

input - a data stream containing raw FAST messages

templateStream - a stream from which the FAST templates can be read.

output - An object to accept the decoded messages.

FastMessageReader

public FastMessageReader(InputStream input,
                 InputStream templateStream,
                 FastMessageConsumer output,
                 int readOffset)

Construct the reader.

Parameters:

input - a data stream containing raw FAST messages

templateStream - a stream from which the FAST templates can be read.

output - An object to accept the decoded messages.

readOffset - The number of leading bytes that should be discarded when reading each message.

Method Detail

start

public void start()

setHead

public void setHead(int count)

Limit the number of records to be processed

Parameters:

count - How many records to handle; zero means no limit.

showRawData

public void showRawData(boolean flag)

Set flag to call the output annotate message with raw data in hex.

Parameters:

flag - true if the raw data should be provided.

resetEveryRecord

public void resetEveryRecord(boolean resetEveryRecord)

Reset the decoder on every record. Some data feeds -- particularly those that use UDB or multicast expect the decoder to start freshe for each incoming record. This flag enables that behavior.

Parameters:

resetEveryRecord - true if each record should stand alone.