Class FixServer
- Namespace
- StockSharp.Server.Fix
- Assembly
- StockSharp.Server.Fix.dll
FIX server.
public class FixServer : BaseLogReceiver, IPersistable, ICloneable<FixServer>, IMessageListener, IMessageChannel, ICloneable<IMessageChannel>, ICloneable, ILogReceiver, ILogSource, IDisposable
- Inheritance
-
FixServer
- Implements
- Inherited Members
- Extension Methods
Constructors
FixServer(IAuthorization, ITransactionIdStorage, string, DateTime)
Initializes a new instance of the FixServer.
public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, DateTime componentTimestamp)
Parameters
authorizationIAuthorizationThe customer authentication.
transactionIdStorageITransactionIdStorageTransaction and request identifiers storage.
licenseFeatureIdstringcomponentTimestampDateTime
FixServer(IAuthorization, ITransactionIdStorage, string, Type)
Initializes a new instance of the FixServer.
public FixServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, Type componentType)
Parameters
authorizationIAuthorizationThe customer authentication.
transactionIdStorageITransactionIdStorageTransaction and request identifiers storage.
licenseFeatureIdstringcomponentTypeType
Properties
Authorization
The customer authentication.
[Browsable(false)]
public IAuthorization Authorization { get; }
Property Value
ComponentTimestamp
Component timestamp.
public DateTime ComponentTimestamp { get; }
Property Value
IsDemo
Demo mode only.
public bool IsDemo { get; }
Property Value
LicenseFeatureId
License feature id to be sent as Logon response.
public string LicenseFeatureId { get; }
Property Value
SendOutHeartbeats
Send via NewOutMessage heartbeat.
public bool SendOutHeartbeats { get; set; }
Property Value
Sessions
Active sessions.
public IEnumerable<IMessageListenerSession> Sessions { get; }
Property Value
Settings
Settings.
public FixServerSettings Settings { get; }
Property Value
State
State.
[Browsable(false)]
public ChannelStates State { get; }
Property Value
TransactionIdStorage
Transaction and request identifiers storage.
[Browsable(false)]
public ITransactionIdStorage TransactionIdStorage { get; }
Property Value
Methods
AddSubscription(ServerSubscription)
Add subscription.
public void AddSubscription(ServerSubscription subscription)
Parameters
subscriptionServerSubscriptionSubscription.
Close()
Close channel.
public void Close()
CreateCondition()
To create the order condition.
protected virtual OrderCondition CreateCondition()
Returns
- OrderCondition
The order condition.
Disconnect(IMessageListenerSession)
Disconnect session.
public void Disconnect(IMessageListenerSession session)
Parameters
sessionIMessageListenerSessionSession.
DisposeManaged()
Release resources.
protected override void DisposeManaged()
GetSubscriptions(IMessageListenerSession)
Get subscription for the specified session.
public IEnumerable<ServerSubscription> GetSubscriptions(IMessageListenerSession session)
Parameters
sessionIMessageListenerSessionSession.
Returns
- IEnumerable<ServerSubscription>
Subscriptions.
HasSubscriptions(DataType, SecurityId)
Are there subscribers.
public bool HasSubscriptions(DataType dataType, SecurityId securityId)
Parameters
dataTypeDataTypeMarket data type.
securityIdSecurityIdSecurity ID.
Returns
- bool
Are there subscribers.
Load(SettingsStorage)
Load settings.
public override void Load(SettingsStorage storage)
Parameters
storageSettingsStorageSettings storage.
OnProcess(FixSession, string, IFixReader)
The method is called when the received message is processing.
protected virtual bool? OnProcess(FixSession session, string msgType, IFixReader reader)
Parameters
sessionFixSessionSession.
msgTypestringMessage type.
readerIFixReaderData reader.
Returns
- bool?
Whether the data was successfully processed.
Open()
Open channel.
public void Open()
PostInitCondition(char, OrderCondition)
The final initialization of the order condition.
protected virtual void PostInitCondition(char ordType, OrderCondition condition)
Parameters
ordTypecharOrder type.
conditionOrderConditionThe order condition.
RaiseNewOutMessage(IMessageListenerSession, Message)
To call the event NewOutMessage.
protected void RaiseNewOutMessage(IMessageListenerSession session, Message message)
Parameters
sessionIMessageListenerSessionSession.
messageMessageMessage.
ReadOrderCondition(IFixReader, FixTags, Func<OrderCondition>)
To read the order condition OrderCondition.
protected virtual bool ReadOrderCondition(IFixReader reader, FixTags tag, Func<OrderCondition> getCondition)
Parameters
readerIFixReaderData reader.
tagFixTagsTag.
getConditionFunc<OrderCondition>The function returning the order condition.
Returns
- bool
Whether the data was successfully processed.
RemoveSubscription(ServerSubscription)
Remove subscription.
public bool RemoveSubscription(ServerSubscription subscription)
Parameters
subscriptionServerSubscriptionSubscription.
Returns
Resume(IMessageListenerSession)
Resume session.
public void Resume(IMessageListenerSession session)
Parameters
sessionIMessageListenerSessionSession.
Resume(ServerSubscription)
Resume subscription.
public bool Resume(ServerSubscription subscription)
Parameters
subscriptionServerSubscriptionSubscription.
Returns
Save(SettingsStorage)
Save settings.
public override void Save(SettingsStorage storage)
Parameters
storageSettingsStorageSettings storage.
SendInMessage(Message)
Send message.
public bool SendInMessage(Message message)
Parameters
messageMessageMessage.
Returns
SendInMessage(IMessageListenerSession, long?, Message)
public bool SendInMessage(IMessageListenerSession session, long? subscriptionId, Message message)
Parameters
sessionIMessageListenerSessionsubscriptionIdlong?messageMessage
Returns
Suspend(IMessageListenerSession)
Suspend session.
public void Suspend(IMessageListenerSession session)
Parameters
sessionIMessageListenerSessionSession.
Suspend(ServerSubscription)
Suspend subscription.
public bool Suspend(ServerSubscription subscription)
Parameters
subscriptionServerSubscriptionSubscription.
Returns
WriterFixOrderCondition(IFixWriter, OrderCondition)
To record data by the order condition.
protected virtual void WriterFixOrderCondition(IFixWriter writer, OrderCondition condition)
Parameters
writerIFixWriterFIX data writer.
conditionOrderConditionOrder condition (e.g., stop- and algo- orders parameters).
Events
NewOutMessage
New message event.
public event Action<IMessageListenerSession, Message> NewOutMessage
Event Type
SessionConnected
Session connected event.
public event Action<IMessageListenerSession> SessionConnected
Event Type
SessionDisconnected
Session disconnected event.
public event Action<IMessageListenerSession> SessionDisconnected
Event Type
StateChanged
State change event.
public event Action StateChanged
Event Type
SubscriptionChanged
Client subscription changed event.
public event Action<ServerSubscription> SubscriptionChanged