org.openfast

Class MessageInputStream

java.lang.Object

org.openfast.MessageInputStream

All Implemented Interfaces:

MessageStream

public class MessageInputStream
extends Object
implements MessageStream

Constructor Summary

Constructors

Constructor and Description
MessageInputStream(InputStream inputStream)
MessageInputStream(InputStream inputStream, Context context)

Method Summary

Methods

Modifier and Type	Method and Description
void	addMessageHandler(MessageHandler handler)
void	addMessageHandler(MessageTemplate template, MessageHandler handler)
void	addTemplateRegisteredListener(TemplateRegisteredListener templateRegisteredListener)
void	close()
Context	getContext()
TemplateRegistry	getTemplateRegistry()
InputStream	getUnderlyingStream()
Message	readMessage() Decodes the next message in the input stream if a message is found.
void	registerTemplate(int templateId, MessageTemplate template)
void	reset()
void	setBlockReader(MessageBlockReader messageBlockReader)
void	setTemplateRegistry(TemplateRegistry registry)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageInputStream

public MessageInputStream(InputStream inputStream)

MessageInputStream

public MessageInputStream(InputStream inputStream,
                  Context context)

Method Detail

readMessage

public Message readMessage()

Decodes the next message in the input stream if a message is found. If no more messages are present in the stream, null is returned. If a partial message is encountered a FastException with error code 104 is thrown (see FastConstants.END_OF_STREAM).

Returns:

the next message in the stream or null if no more messages are encountered in the stream

Throws:

FastException

registerTemplate

public void registerTemplate(int templateId,
                    MessageTemplate template)

close

public void close()

Specified by:

close in interface MessageStream

getUnderlyingStream

public InputStream getUnderlyingStream()

addMessageHandler

public void addMessageHandler(MessageTemplate template,
                     MessageHandler handler)

Specified by:

addMessageHandler in interface MessageStream

addMessageHandler

public void addMessageHandler(MessageHandler handler)

Specified by:

addMessageHandler in interface MessageStream

setTemplateRegistry

public void setTemplateRegistry(TemplateRegistry registry)

getTemplateRegistry

public TemplateRegistry getTemplateRegistry()

Specified by:

getTemplateRegistry in interface MessageStream

addTemplateRegisteredListener

public void addTemplateRegisteredListener(TemplateRegisteredListener templateRegisteredListener)

reset

public void reset()

getContext

public Context getContext()

setBlockReader

public void setBlockReader(MessageBlockReader messageBlockReader)