Skip to content

Commit

Permalink
corrections to IInitiator refactor; add ResetOnXXX to executor.cfg
Browse files Browse the repository at this point in the history
  • Loading branch information
gbirchmeier committed Oct 20, 2011
1 parent 90ac20d commit 7d74d6f
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 26 deletions.
3 changes: 3 additions & 0 deletions Examples/Executor/executor.cfg
Expand Up @@ -6,6 +6,9 @@ StartTime=00:00:00
EndTime=00:00:00 EndTime=00:00:00
FileLogPath=log FileLogPath=log
UseDataDictionary=Y UseDataDictionary=Y
ResetOnLogon=Y
ResetOnLogout=Y
ResetOnDisconnect=Y


[SESSION] [SESSION]
BeginString=FIX.4.0 BeginString=FIX.4.0
Expand Down
3 changes: 1 addition & 2 deletions QuickFIX.NET/AbstractInitiator.cs
Expand Up @@ -3,7 +3,7 @@


namespace QuickFix namespace QuickFix
{ {
public abstract class AbstractInitiator public abstract class AbstractInitiator : IInitiator
{ {
private object sync_ = new object(); private object sync_ = new object();
private Dictionary<SessionID,Session> sessions_ = new Dictionary<SessionID, Session>(); private Dictionary<SessionID,Session> sessions_ = new Dictionary<SessionID, Session>();
Expand Down Expand Up @@ -112,7 +112,6 @@ public bool IsLoggedOn()
{ {
lock (sync_) lock (sync_)
{ {

foreach (SessionID sessionID in connected_) foreach (SessionID sessionID in connected_)
{ {
if (Session.LookupSession(sessionID).IsLoggedOn) if (Session.LookupSession(sessionID).IsLoggedOn)
Expand Down
24 changes: 0 additions & 24 deletions QuickFIX.NET/IInitiator.cs
Expand Up @@ -18,29 +18,5 @@ public interface IInitiator
void Stop(bool force); void Stop(bool force);


bool IsLoggedOn(); bool IsLoggedOn();

/// <summary>
/// Start connecting to targets.
/// </summary>
void OnStart();

/// <summary>
/// Connect and poll for events.
/// </summary>
/// <param name="timeout"></param>
/// <returns></returns>
bool OnPoll(double timeout);

/// <summary>
/// Stop a running initiator.
/// </summary>
void OnStop();

/// <summary>
/// Connect a session to its target.
/// </summary>
/// <param name="sessionID"></param>
/// <param name="settings"></param>
void DoConnect(SessionID sessionID, QuickFix.Dictionary settings);
} }
} }

0 comments on commit 7d74d6f

Please sign in to comment.