Show / Hide Table of Contents

Class FixServer

FIX server.

Inheritance
Object
BaseLogSource
BaseLogReceiver
FixServer
Implements
Ecng.Serialization.IPersistable
Ecng.Common.ICloneable<FixServer>
IMessageListener
ILogReceiver
ILogSource
IMessageChannel
IDisposable
Ecng.Common.ICloneable<IMessageChannel>
ICloneable
Inherited Members
BaseLogReceiver.ILogReceiver.AddLog(LogMessage)
BaseLogSource.RaiseLog(LogMessage)
BaseLogSource.ToString()
BaseLogSource.Id
BaseLogSource.Name
BaseLogSource.Parent
BaseLogSource.LogLevel
BaseLogSource.CurrentTime
BaseLogSource.IsRoot
BaseLogSource.ParentRemoved
BaseLogSource.Log
Namespace: StockSharp.Server.Fix
Assembly: StockSharp.Server.Fix.dll
Syntax
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)
☀
☾
In This Article
Back to top
Copyright © StockSharp.
☀
☾