org.openfast.examples.producer

Class MulticastFastMessageProducer

java.lang.Object

org.openfast.examples.producer.FastMessageProducer

org.openfast.examples.producer.MulticastFastMessageProducer

All Implemented Interfaces:

ConnectionListener

public class MulticastFastMessageProducer
extends FastMessageProducer

Field Summary

Fields inherited from class org.openfast.examples.producer.FastMessageProducer

acceptThread, connections, converter, endpoint, messageBlockWriterFactory, shouldResetOnEveryMessage, templateRegistry

Fields inherited from interface org.openfast.session.ConnectionListener

NULL

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	onConnect(Connection connection)
protected void	publish(List messages, List msgOutputStreams)
void	start()

Methods inherited from class org.openfast.examples.producer.FastMessageProducer

encode, encode, encode, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

MulticastFastMessageProducer

public MulticastFastMessageProducer(Endpoint endpoint,
                            File templatesFile)
                             throws IOException,
                                    FastConnectionException

Throws:

IOException

FastConnectionException

MulticastFastMessageProducer

public MulticastFastMessageProducer(Endpoint endpoint,
                            File templatesFile,
                            MessageBlockWriterFactory messageBlockWriterFactory,
                            boolean shouldResetOnEveryMessage)
                             throws IOException,
                                    FastConnectionException

Throws:

IOException

FastConnectionException

Method Detail

publish

protected void publish(List messages,
           List msgOutputStreams)

Overrides:

publish in class FastMessageProducer

start

public void start()

Overrides:

start in class FastMessageProducer

onConnect

public void onConnect(Connection connection)

Specified by:

onConnect in interface ConnectionListener

Overrides:

onConnect in class FastMessageProducer