Class NoQueueMessagePumper

Inheritance

System.Object

NoQueueMessagePumper

Implements

IMessagePumper

IWorkerThread

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

IMessagePumper

IWorkerThread