com.epam.bovespafast.impl.message

Class MessageChopper

java.lang.Object

com.epam.bovespafast.impl.message.MessageChopper

All Implemented Interfaces:

StreamListener

public class MessageChopper
extends Object
implements StreamListener

Class provide processing of all messages. These messages should be processed before user can handle it.

Class can work with incremental and recovery stream. To use this class user should create increment or recovery transports and pass this instance to connect or disconnect methods of transport methods.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	MessageChopper.MessageProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected static com.epam.common.logging.Log	log

Constructor Summary

Constructors

Constructor and Description
MessageChopper(ChannelContext context)

Method Summary

Modifier and Type	Method and Description
void	onMessage(com.epam.fix.message.FIXFieldList message) Invoked when new message received.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final com.epam.common.logging.Log log

Constructor Detail

MessageChopper

public MessageChopper(ChannelContext context)

Method Detail

onMessage

public void onMessage(com.epam.fix.message.FIXFieldList message)

Description copied from interface: StreamListener

Invoked when new message received.

Specified by:

onMessage in interface StreamListener

Parameters:

message - the message