Class FixMessageChopper

Slices FIX messages from the InputStream or Transport implementations.

Inheritance

System.Object

FixMessageChopper

Implements

IMessageChopper

Inherited Members

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: FixAntenna.FixEngine.Transport

Assembly: FixAntenna.Core.dll

Syntax

public sealed class FixMessageChopper : IMessageChopper

Constructors

FixMessageChopper(ITransport, Int32, Int32)

Creates FIXMessageChopper with specified message size limit.

Declaration

public FixMessageChopper(ITransport transport, int maxMessageSize, int optimalBufferLength)

Parameters

Type	Name	Description
ITransport	transport	the transport implementation to read from.
System.Int32	maxMessageSize	the message size limit.
System.Int32	optimalBufferLength	the optimal length of internal buffer

FixMessageChopper(ITransport, Int32, Int32, Boolean, Boolean)

Creates FIXMessageChopper with specified message size limit.

Declaration

public FixMessageChopper(ITransport transport, int maxMessageSize, int optimalBufferLength, bool validateCheckSum, bool markInMessageTime)

Parameters

Type	Name	Description
ITransport	transport	the transport implementation to read from.
System.Int32	maxMessageSize	the message size limit.
System.Int32	optimalBufferLength	the optimal length of internal buffer
System.Boolean	validateCheckSum	do not validate CheckSum(10) if this flag is set to false
System.Boolean	markInMessageTime

FixMessageChopper(Stream, Int32, Int32)

Creates FIXMessageChopper with specified message size limit.

Declaration

public FixMessageChopper(Stream inputStream, int maxMessageSize, int optimalBufferLength)

Parameters

Type	Name	Description
System.IO.Stream	inputStream	the input stream to read from.
System.Int32	maxMessageSize	the message size limit.
System.Int32	optimalBufferLength	the optimal length of internal buffer

FixMessageChopper(Stream, Int32, Int32, Boolean)

Creates FIXMessageChopper with specified message size limit.

Declaration

public FixMessageChopper(Stream inputStream, int maxMessageSize, int optimalBufferLength, bool validateCheckSum)

Parameters

Type	Name	Description
System.IO.Stream	inputStream	the input stream to read from.
System.Int32	maxMessageSize	the message size limit.
System.Int32	optimalBufferLength	the optimal length of internal buffer
System.Boolean	validateCheckSum	do not validate CheckSum(10) if this flag is set to false

Properties

RawTags

Declaration

public RawFixUtil.IRawTags RawTags { get; set; }

Property Value

Type	Description
RawFixUtil.IRawTags

Methods

GetBuffer()

Gets buffer

Declaration

public byte[] GetBuffer()

Returns

Type	Description
System.Byte[]	buffer

GetError()

Returns error of last read message if message is garbled or null otherwise.

Declaration

public GarbledMessageError GetError()

Returns

Type	Description
GarbledMessageError	the instance of error enum.

GetErrorPosition()

Returns error position of last read message if message is garbled or -1 otherwise.

Declaration

public int GetErrorPosition()

Returns

Type	Description
System.Int32	the error message string.

GetMessageReadTimeInTicks()

Declaration

public long GetMessageReadTimeInTicks()

Returns

Type	Description
System.Int64

IsMessageGarbled()

Returns true if last read message is garbled.

Declaration

public bool IsMessageGarbled()

Returns

Type	Description
System.Boolean	true if last read message is garbled.

OnMessageEnd()

Declaration

public void OnMessageEnd()

OnMessageStart()

Declaration

public void OnMessageStart()

ReadMessage(MsgBuf)

Read next message (garbled or non garbled) from the InputStream or Transport implementations.

Declaration

public void ReadMessage(MsgBuf buf)

Parameters

Type	Name	Description
MsgBuf	buf

Exceptions

Type	Condition
System.IO.IOException	if some I/O error occurs, or end of file read, or message is too long.

Reset()

Declaration

public void Reset()

SetUserParserListener(IFixParserListener)

Declaration

public void SetUserParserListener(IFixParserListener parserListener)

Parameters

Type	Name	Description
IFixParserListener	parserListener

Implements

IMessageChopper