Class FixServer
FIX server.
Implements
Inherited Members
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
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
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= |