To update QuickFIX/Go to the latest version, use:

go get -u github.com/quickfixgo/quickfix

Everything needed to generate your database is in the _sql directory. For MySQL, there are the script and batch files create.sh and create.bat. These scripts will work on a newly installed MySQL database with default permisions. The scripts will try to generate the database using the root MySQL account with no password. If you need to use a different account or need a password, you will have to edit the script. To select a different user, simply change 'root' to another user. To add a password, use pass the -p option after the username. Similar scripts are provided for MSSQL, PostgreSQL and Oracle.

package quickfix
type Application interface {
//Notification of a session begin created.
OnCreate(sessionID SessionID)
//Notification of a session successfully logging on.
OnLogon(sessionID SessionID)
//Notification of a session logging off or disconnecting.
OnLogout(sessionID SessionID)
//Notification of admin message being sent to target.
ToAdmin(message Message, sessionID SessionID)
//Notification of app message being sent to target.
ToApp(message Message, sessionID SessionID) error
//Notification of admin message being received from target.
FromAdmin(message Message, sessionID SessionID) MessageRejectError
//Notification of app message being received from target.
FromApp(message Message, sessionID SessionID) MessageRejectError
}

package main

import (
"flag"
"github.com/quickfixgo/quickfix"
"os"
)

func main() {
flag.Parse()
fileName := flag.Arg(0)

//FooApplication is your type that implements the Application interface
var app FooApplication

cfg, _ := os.Open(fileName)
appSettings, _ := quickfix.ParseSettings(cfg)
storeFactory := quickfix.NewMemoryStoreFactory()
logFactory, _ := quickfix.NewFileLogFactory(appSettings)
acceptor, _ := quickfix.NewAcceptor(app, storeFactory, appSettings, logFactory)

_ = acceptor.Start()
//for condition == true { do something }
acceptor.Stop()
}

• Session
• Validation
• Initiator
• Acceptor
• Secure Communication
• Storage
• Logging

DefaultApplVerID=FIX.4.2
# For default application version ID
AppDataDictionary=FIX42.xml
# For nondefault application version ID
# Use BeginString suffix for app version
AppDataDictionary.FIX.4.4=FIX44.xml
        

SQLStoreConnMaxLifetime=14400s # 14400 seconds
SQLStoreConnMaxLifetime=2h45m  # 2 hours and 45 minutes
        

# default settings for sessions
[DEFAULT]
ReconnectInterval=60
SenderCompID=TW

# session definition
[SESSION]
# inherit ReconnectInterval and SenderCompID from default
BeginString=FIX.4.1
TargetCompID=ARCA
StartTime=12:30:00
EndTime=23:30:00
HeartBtInt=20
SocketConnectPort=9823
SocketConnectHost=123.123.123.123
DataDictionary=somewhere/FIX41.xml

[SESSION]
BeginString=FIX.4.0
TargetCompID=ISLD
StartTime=12:00:00
EndTime=23:00:00
HeartBtInt=30
SocketConnectPort=8323
SocketConnectHost=23.23.23.23
DataDictionary=somewhere/FIX40.xml

[SESSION]
BeginString=FIX.4.2
TargetCompID=INCA
StartTime=12:30:00
EndTime=21:30:00
# overide default setting for RecconnectInterval
ReconnectInterval=30
HeartBtInt=30
SocketConnectPort=6523
SocketConnectHost=3.3.3.3
# (optional) alternate connection ports and hosts to cycle through on failover
SocketConnectPort1=8392
SocketConnectHost1=8.8.8.8
SocketConnectPort2=2932
SocketConnectHost2=12.12.12.12
DataDictionary=somewhere/FIX42.xml

<fix type="FIX" major="4" minor="1">
<header>
<field name="BeginString" required="Y"/>
...
</header>
<trailer>
<field name="CheckSum" required="Y"/>
...
</trailer>
<messages>
<message name="Heartbeat" msgtype="0" msgcat="admin">
<field name="TestReqID" required="N"/>
</message>
...
<message name="NewOrderSingle" msgtype="D" msgcat="app">
<field name="ClOrdID" required="Y"/>
...
</message>
...
</messages>
<fields>
<field number="1" name="Account" type="CHAR" />
...
<field number="4" name="AdvSide" type="CHAR">
<value enum="B" description="BUY" />
<value enum="S" description="SELL" />
<value enum="X" description="CROSS" />
<value enum="T" description="TRADE" />
</field>
...
</fields>
</fix>

import (
"github.com/quickfixgo/quickfix"
"github.com/quickfixgo/quickfix/field"
"github.com/quickfixgo/quickfix/fix41/newordersingle"
)

type MyApplication struct {
*quickfix.MessageRouter
}

func (m *MyApplication) init() {
m.MessageRouter=quickfix.NewMessageRouter()
m.AddRoute(newordersingle.Route(m.onNewOrderSingle))
}

func (m *MyApplication) FromApp(msg quickfix.Message, sessionID quickfix.SessionID) (err quickfix.MessageRejectError) {
return m.Route(msg, sessionID)
}

func (m *MyApplication) onNewOrderSingle(msg newordersingle.NewOrderSingle, sessionID quickfix.SessionID) (err quickfix.MessageRejectError) {
clOrdID, err := msg.GetClOrdID()
if err != nil {
return
}

//compile time error!! field not defined in FIX41
clearingAccount, err := msg.GetClearingAccount()

...
return
}

func (m *MyApplication) FromApp(msg quickfix.Message, sessionID quickfix.SessionID) (err quickfix.MessageRejectError) {
var price field.PriceField
if err = msg.Body.Get(&field); err!=nil {
return
}

...
return
}

func (m *MyApplication) FromApp(msg quickfix.Message, sessionID quickfix.SessionID) (err quickfix.MessageRejectError) {
var field quickfix.FIXString
if err = msg.Body.GetField(quickfix.Tag(44), &field); err!=nil {
return
}

...
return
}

//Send determines the session to send Messagable using header fields BeginString, TargetCompID, SenderCompID
func Send(m Messagable) error

//SendToTarget sends Messagable based on the sessionID. Convenient for use in FromApp since it provides a session ID for incoming messages
func SendToTarget(m Messagable, sessionID SessionID) error