Skip to content

Commit 147ca48

Browse files
committed
Corrects mongo pkg ref in test
1 parent fdfb638 commit 147ca48

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

_test/test-server/main.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ import (
1616
field "github.com/quickfixgo/quickfix/gen/field"
1717
tag "github.com/quickfixgo/quickfix/gen/tag"
1818
"github.com/quickfixgo/quickfix/store/file"
19+
"github.com/quickfixgo/quickfix/store/mongo"
1920
)
2021

2122
var router *quickfix.MessageRouter = quickfix.NewMessageRouter()
@@ -150,7 +151,7 @@ func main() {
150151
appSettings.GlobalSettings().Set(config.MongoStoreReplicaSet, mongoReplicaSet)
151152
appSettings.GlobalSettings().Set(config.DynamicSessions, "Y")
152153

153-
acceptor, err = quickfix.NewAcceptor(app, quickfix.NewMongoStoreFactory(appSettings), appSettings, fileLogFactory)
154+
acceptor, err = quickfix.NewAcceptor(app, mongo.NewStoreFactory(appSettings), appSettings, fileLogFactory)
154155
case "FILE":
155156
fileStoreRootPath := path.Join(os.TempDir(), fmt.Sprintf("FileStoreTestSuite-%d", os.Getpid()))
156157
fileStorePath := path.Join(fileStoreRootPath, fmt.Sprintf("%d", time.Now().UnixNano()))

store/file/filestore.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,9 +77,7 @@ func (f fileStoreFactory) Create(sessionID quickfix.SessionID) (msgStore quickfi
7777

7878
dirname, err := sessionSettings.Setting(config.FileStorePath)
7979
if err != nil {
80-
if err != nil {
8180
return nil, err
82-
}
8381
}
8482
var fsync bool
8583
if sessionSettings.HasSetting(config.FileStoreSync) {

0 commit comments

Comments
 (0)