Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Move refresh-interval setting to the correct HOCON path #250

Merged
merged 3 commits into from
Apr 15, 2022
Merged

Move refresh-interval setting to the correct HOCON path #250

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
bac38d5
move akka.persistence.query.journal.sql.refresh-interval setting to t…
Arkatufus Mar 24, 2022
39258a6
Merge branch 'dev' into Fix_query.journal.sql.refresh-interval
Arkatufus Mar 24, 2022
0f52c70
Merge branch 'dev' into Fix_query.journal.sql.refresh-interval
Aaronontheweb Apr 15, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerAllEventsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,13 +29,13 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerCurrentAllEventsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,13 +29,13 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion ...Persistence.SqlServer.Tests/Batching/BatchingSqlServerCurrentEventsByPersistenceIdSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ private static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = DEBUG
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}");

return conf.WithFallback(SqlReadJournal.DefaultConfiguration());
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerCurrentEventsByTagSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ private static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
event-adapters {{
color-tagger = ""Akka.Persistence.TCK.Query.ColorFruitTagger, Akka.Persistence.TCK""
Expand All @@ -43,7 +44,6 @@ class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}");

return conf.WithFallback(SqlReadJournal.DefaultConfiguration());
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerCurrentPersistenceIdsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}");

return conf.WithFallback(SqlReadJournal.DefaultConfiguration());
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerEventsByPersistenceIdSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ private static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = DEBUG
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}");

return conf.WithFallback(SqlReadJournal.DefaultConfiguration());
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerEventsByTagSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ private static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
event-adapters {{
color-tagger = ""Akka.Persistence.TCK.Query.ColorFruitTagger, Akka.Persistence.TCK""
Expand All @@ -43,7 +44,6 @@ class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}");

return conf.WithFallback(SqlReadJournal.DefaultConfiguration());
Expand Down
2 changes: 1 addition & 1 deletion ...kka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerJournalConnectionFailureSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ private static Config CreateSpecConfig(string connectionString)
return ConfigurationFactory.ParseString(@"
akka.persistence {
publish-plugin-commands = on
akka.persistence.query.journal.sql.refresh-interval = 1s
journal {
plugin = ""akka.persistence.journal.sql-server""
sql-server {
Expand All @@ -33,7 +34,6 @@ class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Pers
schema-name = dbo
auto-initialize = on
connection-string = """ + connectionString + @"""
refresh-interval = 1s
}
}
}");
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Batching/BatchingSqlServerPersistenceIdsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 200ms
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.BatchingSqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}");

return conf.WithFallback(SqlReadJournal.DefaultConfiguration());
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerAllEventsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
event-adapters {{
color-tagger = ""Akka.Persistence.TCK.Query.ColorFruitTagger, Akka.Persistence.TCK""
Expand All @@ -42,7 +43,6 @@ class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerCurrentAllEventsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
event-adapters {{
color-tagger = ""Akka.Persistence.TCK.Query.ColorFruitTagger, Akka.Persistence.TCK""
Expand All @@ -42,7 +43,6 @@ class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerCurrentEventsByPersistenceIdSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,14 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerCurrentEventsByTagSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
event-adapters {{
color-tagger = ""Akka.Persistence.TCK.Query.ColorFruitTagger, Akka.Persistence.TCK""
Expand All @@ -42,7 +43,6 @@ class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerCurrentPersistenceIdsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,14 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerEventsByPersistenceIdSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,14 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerEventsByTagSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 1s
akka.persistence.journal.sql-server {{
event-adapters {{
color-tagger = ""Akka.Persistence.TCK.Query.ColorFruitTagger, Akka.Persistence.TCK""
Expand All @@ -42,7 +43,6 @@ class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down
2 changes: 1 addition & 1 deletion src/Akka.Persistence.SqlServer.Tests/Query/SqlServerPersistenceIdsSpec.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,14 @@ public static Config InitConfig(SqlServerFixture fixture)
akka.loglevel = INFO
akka.test.single-expect-default = 10s
akka.persistence.journal.plugin = ""akka.persistence.journal.sql-server""
akka.persistence.query.journal.sql.refresh-interval = 200ms
akka.persistence.journal.sql-server {{
class = ""Akka.Persistence.SqlServer.Journal.SqlServerJournal, Akka.Persistence.SqlServer""
plugin-dispatcher = ""akka.actor.default-dispatcher""
table-name = EventJournal
schema-name = dbo
auto-initialize = on
connection-string = ""{DbUtils.ConnectionString}""
refresh-interval = 1s
}}")
.WithFallback(SqlReadJournal.DefaultConfiguration());
}
Expand Down