Skip to content

Commit 33d4875

Browse files
author
mihaita.tinta
committed
update schemas
Signed-off-by: mihaita.tinta <mihaita.tinta@ing.com>
1 parent 6b4dca2 commit 33d4875

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

spring-modulith-events/spring-modulith-events-jdbc/src/main/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationRepository.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ public JdbcEventPublicationRepository(JdbcOperations operations, EventSerializer
227227

228228
var schema = settings.getSchema();
229229
var table = ObjectUtils.isEmpty(schema) ? "EVENT_PUBLICATION" : schema + ".EVENT_PUBLICATION";
230-
var failedAttemptInfoTable = ObjectUtils.isEmpty(schema) ? "EVENT_FAILED_EVENT_INFO" : schema + ".EVENT_FAILED_EVENT_INFO";
230+
var failedAttemptInfoTable = ObjectUtils.isEmpty(schema) ? "EVENT_FAILED_ATTEMPT_INFO" : schema + ".EVENT_FAILED_ATTEMPT_INFO";
231231
var completedTable = settings.isArchiveCompletion() ? table + "_ARCHIVE" : table;
232232

233233
this.sqlStatementInsert = SQL_STATEMENT_INSERT.formatted(table);

spring-modulith-events/spring-modulith-events-jdbc/src/main/resources/schema-h2.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ CREATE TABLE IF NOT EXISTS EVENT_PUBLICATION
1010
);
1111
CREATE INDEX IF NOT EXISTS EVENT_PUBLICATION_BY_LISTENER_ID_AND_SERIALIZED_EVENT_IDX ON EVENT_PUBLICATION (LISTENER_ID, SERIALIZED_EVENT);
1212
CREATE INDEX IF NOT EXISTS EVENT_PUBLICATION_BY_COMPLETION_DATE_IDX ON EVENT_PUBLICATION (COMPLETION_DATE);
13-
CREATE TABLE IF NOT EXISTS EVENT_FAILED_EVENT_INFO
13+
CREATE TABLE IF NOT EXISTS EVENT_FAILED_ATTEMPT_INFO
1414
(
1515
EVENT_ID UUID NOT NULL,
1616
FAILED_DATE TIMESTAMP(9) WITH TIME ZONE,

spring-modulith-events/spring-modulith-events-jdbc/src/test/java/org/springframework/modulith/events/jdbc/JdbcEventPublicationRepositoryIntegrationTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -456,7 +456,7 @@ String table() {
456456
}
457457

458458
String failedInfoTable() {
459-
return "EVENT_FAILED_EVENT_INFO";
459+
return "EVENT_FAILED_ATTEMPT_INFO";
460460
}
461461

462462
String archiveTable() {

0 commit comments

Comments
 (0)