org.openfast.examples.producer

Class FastMessageProducer

java.lang.Object

org.openfast.examples.producer.FastMessageProducer

All Implemented Interfaces:

ConnectionListener

Direct Known Subclasses:

MulticastFastMessageProducer

public class FastMessageProducer
extends Object
implements ConnectionListener

Field Summary

Fields

Modifier and Type	Field and Description
protected Thread	acceptThread
protected List	connections
protected XmlCompressedMessageConverter	converter
protected Endpoint	endpoint
protected MessageBlockWriterFactory	messageBlockWriterFactory
protected boolean	shouldResetOnEveryMessage
protected TemplateRegistry	templateRegistry

Fields inherited from interface org.openfast.session.ConnectionListener

NULL

Constructor Summary

Constructors

Constructor and Description
FastMessageProducer(Endpoint endpoint, File templatesFile)
FastMessageProducer(Endpoint endpoint, File templatesFile, MessageBlockWriterFactory messageBlockWriterFactory, boolean shouldResetOnEveryMessage)

Method Summary

Methods

Modifier and Type	Method and Description
void	encode(File xmlDataFile)
void	encode(InputStream xmlData)
void	encode(InputStream xmlData, boolean loopForever)
void	onConnect(Connection connection)
protected void	publish(List messages, List msgOutputStreams)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

endpoint

protected final Endpoint endpoint

templateRegistry

protected final TemplateRegistry templateRegistry

acceptThread

protected Thread acceptThread

connections

protected List connections

converter

protected XmlCompressedMessageConverter converter

messageBlockWriterFactory

protected final MessageBlockWriterFactory messageBlockWriterFactory

shouldResetOnEveryMessage

protected final boolean shouldResetOnEveryMessage

Constructor Detail

FastMessageProducer

public FastMessageProducer(Endpoint endpoint,
                   File templatesFile)

FastMessageProducer

public FastMessageProducer(Endpoint endpoint,
                   File templatesFile,
                   MessageBlockWriterFactory messageBlockWriterFactory,
                   boolean shouldResetOnEveryMessage)

Method Detail

encode

public void encode(File xmlDataFile)
            throws FastConnectionException,
                   IOException

Throws:

FastConnectionException

IOException

encode

public void encode(InputStream xmlData)
            throws FastConnectionException,
                   IOException

Throws:

FastConnectionException

IOException

encode

public void encode(InputStream xmlData,
          boolean loopForever)
            throws FastConnectionException,
                   IOException

Throws:

FastConnectionException

IOException

publish

protected void publish(List messages,
           List msgOutputStreams)

start

public void start()

stop

public void stop()

onConnect

public void onConnect(Connection connection)

Specified by:

onConnect in interface ConnectionListener