Skip to content

Commit 0dd076e

Browse files
mattrasbandackleymi
authored andcommitted
Include mongostore in fixes to #484
1 parent 831392f commit 0dd076e

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

mongostore.go

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,9 +61,16 @@ func NewMongoStoreFactoryPrefixed(settings *Settings, collectionsPrefix string)
6161

6262
// Create creates a new MongoStore implementation of the MessageStore interface.
6363
func (f mongoStoreFactory) Create(sessionID SessionID) (msgStore MessageStore, err error) {
64+
globalSettings := f.settings.GlobalSettings()
65+
dynamicSessions, _ := globalSettings.BoolSetting(config.DynamicSessions)
66+
6467
sessionSettings, ok := f.settings.SessionSettings()[sessionID]
6568
if !ok {
66-
return nil, fmt.Errorf("unknown session: %v", sessionID)
69+
if dynamicSessions {
70+
sessionSettings = globalSettings
71+
} else {
72+
return nil, fmt.Errorf("unknown session: %v", sessionID)
73+
}
6774
}
6875
mongoConnectionURL, err := sessionSettings.Setting(config.MongoStoreConnection)
6976
if err != nil {

0 commit comments

Comments
 (0)