Class NoQueueMessagePumper

Inheritance
System.Object
NoQueueMessagePumper
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.Session.IOThreads
Assembly: FixAntenna.Core.dll
Syntax
public class NoQueueMessagePumper : IMessagePumper, IWorkerThread

Constructors

NoQueueMessagePumper(IExtendedFixSession, IQueue<FixMessageWithType>, IMessageStorage, IFixMessageFactory, IFixTransport, ISessionSequenceManager)

Declaration
public NoQueueMessagePumper(IExtendedFixSession extendedFixSession, IQueue<FixMessageWithType> queue, IMessageStorage out, IFixMessageFactory messageFactory, IFixTransport transport, ISessionSequenceManager sequenceManager)
Parameters
Type Name Description
IExtendedFixSession extendedFixSession
IQueue<FixMessageWithType> queue
IMessageStorage out
IFixMessageFactory messageFactory
IFixTransport transport
ISessionSequenceManager sequenceManager

Properties

WorkerThread

Declaration
public Thread WorkerThread { get; }
Property Value
Type Description
System.Threading.Thread

Methods

GetMessageProcessedTimestamp()

Declaration
public long GetMessageProcessedTimestamp()
Returns
Type Description
System.Int64

GetMessageStatistic()

Declaration
public MessageStatistic GetMessageStatistic()
Returns
Type Description
MessageStatistic

Init()

Declaration
public long Init()
Returns
Type Description
System.Int64

IsStatisticEnabled()

Declaration
public bool IsStatisticEnabled()
Returns
Type Description
System.Boolean

Join()

Declaration
public void Join()

Lock()

Declaration
public virtual void Lock()

RejectFirstQueueMessage()

Declaration
public void RejectFirstQueueMessage()

RejectQueueMessages()

Declaration
public void RejectQueueMessages()

Send(FixMessage, Nullable<ChangesType>)

Declaration
public int Send(FixMessage content, ChangesType? allowedChangesType)
Parameters
Type Name Description
FixMessage content
System.Nullable<ChangesType> allowedChangesType
Returns
Type Description
System.Int32

Send(FixMessage, Nullable<ChangesType>, FixSessionSendingType)

Declaration
public int Send(FixMessage content, ChangesType? allowedChangesType, FixSessionSendingType optionMask)
Parameters
Type Name Description
FixMessage content
System.Nullable<ChangesType> allowedChangesType
FixSessionSendingType optionMask
Returns
Type Description
System.Int32

Send(String, FixMessage)

Declaration
public int Send(string type, FixMessage message)
Parameters
Type Name Description
System.String type
FixMessage message
Returns
Type Description
System.Int32

Send(String, FixMessage, FixSessionSendingType)

Declaration
public int Send(string type, FixMessage content, FixSessionSendingType optionMask)
Parameters
Type Name Description
System.String type
FixMessage content
FixSessionSendingType optionMask
Returns
Type Description
System.Int32

SendMessages(Int32)

Declaration
public void SendMessages(int messageCount)
Parameters
Type Name Description
System.Int32 messageCount

SendOutOfTurn(String, FixMessage)

Declaration
public bool SendOutOfTurn(string msgType, FixMessage content)
Parameters
Type Name Description
System.String msgType
FixMessage content
Returns
Type Description
System.Boolean

SetGracefulShutdown(Boolean)

Declaration
public void SetGracefulShutdown(bool gracefulShutdown)
Parameters
Type Name Description
System.Boolean gracefulShutdown

Shutdown()

Declaration
public void Shutdown()

Start()

Declaration
public void Start()

Unlock()

Declaration
public virtual void Unlock()

Implements