Class NewMessageChopper

Slices and parse FIX messages from the Transport implementations.

Inheritance

System.Object

NewMessageChopper

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 NewMessageChopper : IMessageChopper

Constructors

NewMessageChopper(ITransport, Int32, Int32, Boolean)

Creates NewMessageChopper with specified message size limit.

Declaration

public NewMessageChopper(ITransport transport, int maxMessageSize, int optimalBufferLength, bool markInMessageTime)

Parameters

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

NewMessageChopper(ITransport, Int32, Int32, Boolean, IFixParserListener)

Creates NewMessageChopper with specified message size limit.

Declaration

public NewMessageChopper(ITransport transport, int maxMessageSize, int optimalBufferLength, bool markInMessageTime, IFixParserListener parserListener)

Parameters

Type	Name	Description
ITransport	transport	the transport implementstion to read from.
System.Int32	maxMessageSize	the message size limit.
System.Int32	optimalBufferLength	the optimal length of internal buffer
System.Boolean	markInMessageTime
IFixParserListener	parserListener

Fields

SocketReadSize

Declaration

public const int SocketReadSize = 32768

Field Value

Type	Description
System.Int32

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)

Declaration

public void ReadMessage(MsgBuf buf)

Parameters

Type	Name	Description
MsgBuf	buf

Reset()

Declaration

public void Reset()

SetUserParserListener(IFixParserListener)

Declaration

public void SetUserParserListener(IFixParserListener parserListener)

Parameters

Type	Name	Description
IFixParserListener	parserListener

Implements

IMessageChopper