Changed query
This commit is contained in:
parent
b58f980c04
commit
ab21fc76d9
@ -16,7 +16,7 @@ object EventStore: EventStore {
|
|||||||
override fun getPersistedEventsAfter(timestamp: LocalDateTime): List<PersistedEvent> {
|
override fun getPersistedEventsAfter(timestamp: LocalDateTime): List<PersistedEvent> {
|
||||||
val result = withTransaction {
|
val result = withTransaction {
|
||||||
EventsTable.selectAll()
|
EventsTable.selectAll()
|
||||||
.where { EventsTable.persistedAt greaterEq timestamp }
|
.where { EventsTable.persistedAt greater timestamp }
|
||||||
.map {
|
.map {
|
||||||
PersistedEvent(
|
PersistedEvent(
|
||||||
id = it[EventsTable.id].value.toLong(),
|
id = it[EventsTable.id].value.toLong(),
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user