Class FixMessageChopper
Slices FIX messages from the InputStream
or Transport
implementations.
Inheritance
Implements
Inherited Members
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 |