Class FixServer

public class FixServer : BaseLogReceiver, IPersistable, ICloneable<FixServer>, IMessageListener, ILogReceiver, ILogSource, IMessageChannel, IDisposable, ICloneable<IMessageChannel>, ICloneable

Constructors

FixServer(IAuthorization, ITransactionIdStorage)

Initializes a new instance of the FixServer.

Declaration

public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage)

Parameters

Type	Name	Description
Ecng.Security.IAuthorization	authorization	The customer authentication.
ITransactionIdStorage	transactionIdStorage	Transaction and request identifiers storage.

Properties

Authorization

The customer authentication.

Declaration

public IAuthorization Authorization { get; }

Property Value

Type	Description
Ecng.Security.IAuthorization

SendOutHeartbeats

Send via NewOutMessage heartbeat.

Declaration

public bool SendOutHeartbeats { get; set; }

Property Value

Type	Description
Boolean

Sessions

Active sessions.

Declaration

public IEnumerable<IMessageListenerSession> Sessions { get; }

Property Value

Type	Description
IEnumerable<IMessageListenerSession>

Settings

Settings.

Declaration

public FixServerSettings Settings { get; }

Property Value

Type	Description
FixServerSettings

State

State.

Declaration

public ChannelStates State { get; }

Property Value

Type	Description
ChannelStates

TransactionIdStorage

Transaction and request identifiers storage.

Declaration

public ITransactionIdStorage TransactionIdStorage { get; }

Property Value

Type	Description
ITransactionIdStorage

Methods

AddSubscription(ServerSubscription)

Add subscription.

Declaration

public void AddSubscription(ServerSubscription subscription)

Parameters

Type	Name	Description
ServerSubscription	subscription	Subscription.

Close()

Close channel.

Declaration

public void Close()

CreateCondition()

To create the order condition.

Declaration

protected virtual OrderCondition CreateCondition()

Returns

Type	Description
OrderCondition	The order condition.

Disconnect(IMessageListenerSession)

Disconnect session.

Declaration

public void Disconnect(IMessageListenerSession session)

Parameters

Type	Name	Description
IMessageListenerSession	session	Session.

DisposeManaged()

Release resources.

Declaration

protected override void DisposeManaged()

GetSubscriptions(IMessageListenerSession)

Get subscription for the specified session.

Declaration

public IEnumerable<ServerSubscription> GetSubscriptions(IMessageListenerSession session)

Parameters

Type	Name	Description
IMessageListenerSession	session	Session.

Returns

Type	Description
IEnumerable<ServerSubscription>	Subscriptions.

HasSubscriptions(DataType, SecurityId)

Are there subscribers.

Declaration

public bool HasSubscriptions(DataType dataType, SecurityId securityId)

Parameters

Type	Name	Description
DataType	dataType	Market data type.
SecurityId	securityId	Security ID.

Returns

Type	Description
Boolean	Are there subscribers.

Load(SettingsStorage)

Load settings.

Declaration

public override void Load(SettingsStorage storage)

Parameters

Type	Name	Description
Ecng.Serialization.SettingsStorage	storage	Settings storage.

Overrides

BaseLogSource.Load(SettingsStorage)

OnProcess(FixSession, String, IFixReader)

The method is called when the received message is processing.

Declaration

protected virtual Nullable<bool> OnProcess(FixSession session, string msgType, IFixReader reader)

Parameters

Type	Name	Description
FixSession	session	Session.
String	msgType	Message type.
IFixReader	reader	Data reader.

Returns

Type	Description
Nullable<Boolean>	Whether the data was successfully processed.

Open()

Open channel.

Declaration

public void Open()

PostInitCondition(Char, OrderCondition)

The final initialization of the order condition.

Declaration

protected virtual void PostInitCondition(char ordType, OrderCondition condition)

Parameters

Type	Name	Description
Char	ordType	Order type.
OrderCondition	condition	The order condition.

RaiseNewOutMessage(IMessageListenerSession, Message)

To call the event NewOutMessage.

Declaration

protected void RaiseNewOutMessage(IMessageListenerSession session, Message message)

Parameters

Type	Name	Description
IMessageListenerSession	session	Session.
Message	message	Message.

ReadOrderCondition(IFixReader, FixTags, Func<OrderCondition>)

To read the order condition OrderCondition.

Declaration

protected virtual bool ReadOrderCondition(IFixReader reader, FixTags tag, Func<OrderCondition> getCondition)

Parameters

Type	Name	Description
IFixReader	reader	Data reader.
FixTags	tag	Tag.
Func<OrderCondition>	getCondition	The function returning the order condition.

Returns

Type	Description
Boolean	Whether the data was successfully processed.

RemoveSubscription(ServerSubscription)

Remove subscription.

Declaration

public bool RemoveSubscription(ServerSubscription subscription)

Parameters

Type	Name	Description
ServerSubscription	subscription	Subscription.

Returns

Type	Description
Boolean	true if subscription was found, otherwise false.

Resume(IMessageListenerSession)

Resume session.

Declaration

public void Resume(IMessageListenerSession session)

Parameters

Type	Name	Description
IMessageListenerSession	session	Session.

Resume(ServerSubscription)

Resume subscription.

Declaration

public bool Resume(ServerSubscription subscription)

Parameters

Type	Name	Description
ServerSubscription	subscription	Subscription.

Returns

Type	Description
Boolean	true if subscription was found, otherwise false.

Save(SettingsStorage)

Save settings.

Declaration

public override void Save(SettingsStorage storage)

Parameters

Type	Name	Description
Ecng.Serialization.SettingsStorage	storage	Settings storage.

Overrides

BaseLogSource.Save(SettingsStorage)

SendInMessage(Message)

Send message.

Declaration

public bool SendInMessage(Message message)

Parameters

Type	Name	Description
Message	message	Message.

Returns

Type	Description
Boolean	true if the specified message was processed successfully, otherwise, false.

SendInMessage(IMessageListenerSession, Nullable<Int64>, Message)

Send message.

Declaration

public bool SendInMessage(IMessageListenerSession session, Nullable<long> subscriptionId, Message message)

Parameters

Type	Name	Description
IMessageListenerSession	session	Session.
Nullable<Int64>	subscriptionId	Subscription id.
Message	message	Message.

Returns

Type	Description
Boolean	true if the specified message was processed successfully, otherwise, false.

Suspend(IMessageListenerSession)

Suspend session.

Declaration

public void Suspend(IMessageListenerSession session)

Parameters

Type	Name	Description
IMessageListenerSession	session	Session.

Suspend(ServerSubscription)

Suspend subscription.

Declaration

public bool Suspend(ServerSubscription subscription)

Parameters

Type	Name	Description
ServerSubscription	subscription	Subscription.

Returns

Type	Description
Boolean	true if subscription was found, otherwise false.

WriterFixOrderCondition(IFixWriter, OrderCondition)

To record data by the order condition.

Declaration

protected virtual void WriterFixOrderCondition(IFixWriter writer, OrderCondition condition)

Parameters

Type	Name	Description
IFixWriter	writer	FIX data writer.
OrderCondition	condition	Order condition (e.g., stop- and algo- orders parameters).

Events

NewOutMessage

New message event.

Declaration

public event Action<IMessageListenerSession, Message> NewOutMessage

Event Type

Type	Description
Action<IMessageListenerSession, Message>

SessionConnected

Session connected event.

Declaration

public event Action<IMessageListenerSession> SessionConnected

Event Type

Type	Description
Action<IMessageListenerSession>

SessionDisconnected

Session disconnected event.

Declaration

public event Action<IMessageListenerSession> SessionDisconnected

Event Type

Type	Description
Action<IMessageListenerSession>

StateChanged

State change event.

Declaration

public event Action StateChanged

Event Type

Type	Description
Action

SubscriptionChanged

Client subscription changed event.

Declaration

public event Action<ServerSubscription> SubscriptionChanged

Event Type

Type	Description
Action<ServerSubscription>

Explicit Interface Implementations

IMessageChannel.add_NewOutMessage(Action<Message>)

Declaration

void IMessageChannel.add_NewOutMessage(Action<Message> #=zqtYEras=)

Parameters

Type	Name	Description
Action<Message>	#=zqtYEras=

IMessageChannel.remove_NewOutMessage(Action<Message>)

Declaration

void IMessageChannel.remove_NewOutMessage(Action<Message> #=zqtYEras=)

Parameters

Type	Name	Description
Action<Message>	#=zqtYEras=

IMessageChannel.Clear()

Declaration

void IMessageChannel.Clear()

IMessageChannel.Suspend()

Declaration

void IMessageChannel.Suspend()

IMessageListener.get_KeepSubscriptionsOnDisconnect()

Declaration

bool IMessageListener.get_KeepSubscriptionsOnDisconnect()

Returns

Type	Description
Boolean

IMessageChannel.Resume()

Declaration

void IMessageChannel.Resume()

IMessageListener.set_KeepSubscriptionsOnDisconnect(Boolean)

Declaration

void IMessageListener.set_KeepSubscriptionsOnDisconnect(bool #=zqtYEras=)

Parameters

Type	Name	Description
Boolean	#=zqtYEras=

Implements

Ecng.Serialization.IPersistable

Ecng.Common.ICloneable<>

IMessageListener

ILogReceiver

ILogSource

IMessageChannel

System.IDisposable

Ecng.Common.ICloneable<>

System.ICloneable

Extension Methods

Paths.Serialize<T>(T, String)

Paths.Serialize<T>(T)

EditorExtensions.ToItemsSource(Object, Type, Nullable<Boolean>, Nullable<ListSortDirection>, Func<IItemsSourceItem, Boolean>, Func<Object, String>, Func<Object, String>)

XamlHelper.WpfCast<T>(Object)

XamlHelper.CopyToClipboard<T>(T)

XamlHelper.EnsureUIThread(Object)