org.openfast.examples.consumer

Class FastMessageConsumer

java.lang.Object

org.openfast.examples.consumer.FastMessageConsumer

public class FastMessageConsumer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected MessageBlockReaderFactory	messageBlockReaderFactory
protected boolean	shouldResetOnEveryMessage

Constructor Summary

Constructors

Constructor and Description
FastMessageConsumer(Endpoint endpoint, File templatesFile)
FastMessageConsumer(Endpoint endpoint, File templatesFile, MessageBlockReaderFactory messageBlockReaderFactory, boolean shouldResetOnEveryMessage)

Method Summary

Methods

Modifier and Type	Method and Description
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

messageBlockReaderFactory

protected final MessageBlockReaderFactory messageBlockReaderFactory

shouldResetOnEveryMessage

protected final boolean shouldResetOnEveryMessage

Constructor Detail

FastMessageConsumer

public FastMessageConsumer(Endpoint endpoint,
                   File templatesFile)

FastMessageConsumer

public FastMessageConsumer(Endpoint endpoint,
                   File templatesFile,
                   MessageBlockReaderFactory messageBlockReaderFactory,
                   boolean shouldResetOnEveryMessage)

Method Detail

start

public void start()
           throws FastConnectionException,
                  IOException

Throws:

FastConnectionException

IOException