org.openfast
Class MessageInputStream

java.lang.Object
  org.openfast.MessageInputStream

All Implemented Interfaces:

MessageStream

public class MessageInputStream
extends java.lang.Object
implements MessageStream

Constructor Summary

MessageInputStream(java.io.InputStream inputStream)

MessageInputStream(java.io.InputStream inputStream, Context context)

Method Summary

void	addMessageHandler(MessageHandler handler)
void	addMessageHandler(MessageTemplate template, MessageHandler handler)
void	addTemplateRegisteredListener(TemplateRegisteredListener templateRegisteredListener)
void	close()
Context	getContext()
TemplateRegistry	getTemplateRegistry()
java.io.InputStream	getUnderlyingStream()
Message	readMessage()
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(java.io.InputStream inputStream)

MessageInputStream

public MessageInputStream(java.io.InputStream inputStream,
                          Context context)

Method Detail

readMessage

public Message readMessage()

Returns:

the next message in the stream

Throws:

java.io.EOFException

registerTemplate

public void registerTemplate(int templateId,
                             MessageTemplate template)

close

public void close()

Specified by:

close in interface MessageStream

getUnderlyingStream

public java.io.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)