From cf240bd0bcd666b59c445e06dca0e3c1457693f7 Mon Sep 17 00:00:00 2001 From: dhommen Date: Wed, 3 Jul 2024 20:31:40 +0200 Subject: [PATCH 1/7] chore: upgrade deprecated setup-gradle action --- .github/workflows/publish.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/publish.yml b/.github/workflows/publish.yml index 824e0de..2aeaf72 100644 --- a/.github/workflows/publish.yml +++ b/.github/workflows/publish.yml @@ -25,7 +25,7 @@ jobs: - name: Validate Gradle wrapper uses: gradle/actions/wrapper-validation@v3 - name: Publish - uses: gradle/gradle-build-action@v3 + uses: gradle/actions/setup-gradle@v3 with: arguments: -Pversion=${{ env.IMAGE_TAG }} publish env: From b12aa3d020d217f25b2427a77fd0ecf35012cf2b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Sch=C3=B6nenberg?= Date: Thu, 4 Jul 2024 07:40:47 +0200 Subject: [PATCH 2/7] feat: receive and store receipt into database --- .../spi/store/LoggingHouseMessageStore.java | 2 +- .../sql/SqlLoggingHouseMessageStore.java | 21 +++++++----------- .../sql/schema/BaseSqlDialectStatements.java | 6 ++--- .../schema/LoggingHouseEventStatements.java | 4 ++++ .../client/worker/MessageWorker.java | 20 ++++++++--------- .../logginghouse/V0_0_2__Update_Tables.sql | 22 +++++++++++++++++++ 6 files changed, 48 insertions(+), 27 deletions(-) create mode 100644 logging-house-client/src/main/resources/migration/logginghouse/V0_0_2__Update_Tables.sql diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/spi/store/LoggingHouseMessageStore.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/spi/store/LoggingHouseMessageStore.java index 9351161..cca8343 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/spi/store/LoggingHouseMessageStore.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/spi/store/LoggingHouseMessageStore.java @@ -24,5 +24,5 @@ public interface LoggingHouseMessageStore { List listPending(); - void updateSent(long id); + void updateSent(long id, String receipt); } diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java index dc8886a..1db27fd 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java @@ -89,8 +89,7 @@ public List listPending() { return transactionContext.execute(() -> { try { return queryExecutor.query(getConnection(), true, this::mapResultSet, - statements.getSelectPendingStatement(), - LoggingHouseMessageStatus.PENDING.getCode()) + statements.getSelectPendingStatement()) .collect(Collectors.toList()); } catch (SQLException e) { throw new EdcPersistenceException("Error executing SELECT statement", e); @@ -99,12 +98,12 @@ public List listPending() { } @Override - public void updateSent(long id) { + public void updateSent(long id, String receipt) { transactionContext.execute(() -> { try { queryExecutor.execute(getConnection(), statements.getUpdateSentTemplate(), - LoggingHouseMessageStatus.SENT.getCode(), + receipt, mapFromZonedDateTime(ZonedDateTime.now()), id); } catch (SQLException e) { @@ -156,15 +155,11 @@ private LoggingHouseMessage mapResultSet(ResultSet resultSet) throws Exception { } private Class toClass(String eventType) { - - switch (eventType) { - case "ContractAgreement": - return ContractAgreement.class; - case "TransferProcess": - return TransferProcess.class; - default: - throw new EdcException("Invalid eventType: " + eventType); - } + return switch (eventType) { + case "ContractAgreement" -> ContractAgreement.class; + case "TransferProcess" -> TransferProcess.class; + default -> throw new EdcException("Invalid eventType: " + eventType); + }; } } diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java index 56a3010..90d0c6c 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java @@ -38,16 +38,16 @@ public String getInsertTemplate() { @Override public String getSelectPendingStatement() { - return format("SELECT * FROM %s WHERE %s = ?", + return format("SELECT * FROM %s WHERE %s IS NULL", getLoggingHouseMessageTable(), - getStatusColumn()); + getReceiptColumn()); } @Override public String getUpdateSentTemplate() { return format("UPDATE %s SET %s = ?, %s = ? WHERE %s = ?", getLoggingHouseMessageTable(), - getStatusColumn(), + getReceiptColumn(), getSentAtColumn(), getIdColumn()); } diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/LoggingHouseEventStatements.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/LoggingHouseEventStatements.java index 5dd8eea..056e043 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/LoggingHouseEventStatements.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/LoggingHouseEventStatements.java @@ -67,6 +67,10 @@ default String getSentAtColumn() { return "sent_at"; } + default String getReceiptColumn() { + return "receipt"; + } + String getInsertTemplate(); String getSelectPendingStatement(); diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java index 659381e..e691e63 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java @@ -76,24 +76,24 @@ public void process(LoggingHouseMessage message) { var extendedProcessUrl = new URL(loggingHouseUrl + "/process/" + pid); try { createProcess(message, extendedProcessUrl).join(); - } catch (Exception e) { - throw new EdcException("Could not create process in LoggingHouse", e); + // TODO: Not fail when process already exists + monitor.severe("CreateProcess returned error: " + e.getMessage()); + //throw new EdcException("Could not create process in LoggingHouse", e); } } // Log Message var extendedLogUrl = new URL(loggingHouseUrl + "/messages/log/" + pid); try { - logMessage(message, extendedLogUrl).join(); - + var response = logMessage(message, extendedLogUrl).join(); + response.onSuccess(msg -> { + monitor.info("Received receipt successfully from LoggingHouse for message with id " + message.getEventId()); + store.updateSent(message.getId(), msg); + }); } catch (Exception e) { throw new EdcException("Could not log message to LoggingHouse", e); } - - // Update Status - store.updateSent(message.getId()); - } catch (MalformedURLException e) { throw new EdcException("Could not create extended clearinghouse url."); } @@ -111,12 +111,12 @@ public CompletableFuture> createProcess(LoggingHouseMessage return dispatcherRegistry.dispatch(Object.class, logMessage); } - public CompletableFuture> logMessage(LoggingHouseMessage message, URL clearingHouseLogUrl) { + public CompletableFuture> logMessage(LoggingHouseMessage message, URL clearingHouseLogUrl) { monitor.info("Logging message to LoggingHouse with type " + message.getEventType() + " and id " + message.getEventId()); var logMessage = new LogMessage(clearingHouseLogUrl, connectorBaseUrl, message.getEventToLog()); - return dispatcherRegistry.dispatch(Object.class, logMessage); + return dispatcherRegistry.dispatch(String.class, logMessage); } } diff --git a/logging-house-client/src/main/resources/migration/logginghouse/V0_0_2__Update_Tables.sql b/logging-house-client/src/main/resources/migration/logginghouse/V0_0_2__Update_Tables.sql new file mode 100644 index 0000000..cdd7b81 --- /dev/null +++ b/logging-house-client/src/main/resources/migration/logginghouse/V0_0_2__Update_Tables.sql @@ -0,0 +1,22 @@ +-- previous version of the table: +-- +-- CREATE TABLE IF NOT EXISTS edc_logging_house_message +-- ( +-- logging_house_message_id BIGSERIAL NOT NULL, +-- event_type VARCHAR NOT NULL, +-- event_id VARCHAR NOT NULL, +-- event_to_log JSON NOT NULL, +-- create_process BOOLEAN NOT NULL, +-- process_id VARCHAR NOT NULL, +-- consumer_id VARCHAR NOT NULL, +-- provider_id VARCHAR NOT NULL, +-- status VARCHAR NOT NULL, +-- created_at BIGINT NOT NULL, +-- sent_at BIGINT, +-- PRIMARY KEY (logging_house_message_id) +-- ); + +-- remove the status column and add the receipt column, the status is inferred from the receipt (if not null, the status is 'SENT') +ALTER TABLE edc_logging_house_message + DROP COLUMN IF EXISTS status, + ADD COLUMN IF NOT EXISTS receipt VARCHAR; \ No newline at end of file From 7650ed4a052690e10846496655ced698f7206ef3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Sch=C3=B6nenberg?= Date: Thu, 4 Jul 2024 08:02:39 +0200 Subject: [PATCH 3/7] fix: remove status parsing of not existent status column --- .../client/store/sql/SqlLoggingHouseMessageStore.java | 8 ++++---- .../client/store/sql/schema/BaseSqlDialectStatements.java | 3 +-- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java index 1db27fd..095e18d 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java @@ -134,10 +134,10 @@ private LoggingHouseMessage mapResultSet(ResultSet resultSet) throws Exception { } LoggingHouseMessageStatus status; - try { - status = LoggingHouseMessageStatus.codeOf(resultSet.getString(statements.getStatusColumn())); - } catch (EdcPersistenceException e) { - throw new EdcPersistenceException("Error eventToLog JSON column", e); + if (resultSet.getString(statements.getReceiptColumn()) == null) { + status = LoggingHouseMessageStatus.PENDING; + } else { + status = LoggingHouseMessageStatus.SENT; } return LoggingHouseMessage.Builder.newInstance() diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java index 90d0c6c..e497a32 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/schema/BaseSqlDialectStatements.java @@ -21,7 +21,7 @@ public class BaseSqlDialectStatements implements LoggingHouseEventStatements { @Override public String getInsertTemplate() { - return format("INSERT INTO %s (%s, %s, %s, %s, %s, %s, %s, %s, %s) VALUES (?, ?, ?%s, ?, ?, ?, ?, ?, ?)", + return format("INSERT INTO %s (%s, %s, %s, %s, %s, %s, %s, %s) VALUES (?, ?, ?%s, ?, ?, ?, ?, ?)", getLoggingHouseMessageTable(), getEventTypeColumn(), getEventIdColumn(), @@ -30,7 +30,6 @@ public String getInsertTemplate() { getProcessIdColumn(), getConsumerIdColumn(), getProviderIdColumn(), - getStatusColumn(), getCreatedAtColumn(), getFormatAsJsonOperator() ); From 2bbbc9a4d9b3745bf7639b8ed5b9ddf3d6c48026 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Sch=C3=B6nenberg?= Date: Thu, 4 Jul 2024 12:28:15 +0200 Subject: [PATCH 4/7] fix: issue in insert statement, decode receipt --- .../events/messages/LogMessageReceipt.java | 3 +++ .../events/messages/LogMessageSender.java | 19 ++++++++++++++++--- .../sql/SqlLoggingHouseMessageStore.java | 1 - .../client/worker/MessageWorker.java | 9 +++++---- 4 files changed, 24 insertions(+), 8 deletions(-) create mode 100644 logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java new file mode 100644 index 0000000..f4c3457 --- /dev/null +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java @@ -0,0 +1,3 @@ +package com.truzzt.extension.logginghouse.client.events.messages; + +public record LogMessageReceipt (String data) {} diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java index 8371ab1..50af211 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java @@ -14,6 +14,7 @@ package com.truzzt.extension.logginghouse.client.events.messages; +import com.fasterxml.jackson.databind.ObjectMapper; import com.truzzt.extension.logginghouse.client.multipart.ids.jsonld.JsonLd; import com.truzzt.extension.logginghouse.client.multipart.ids.multipart.CalendarUtil; import com.truzzt.extension.logginghouse.client.multipart.ids.multipart.IdsConstants; @@ -32,9 +33,10 @@ import org.eclipse.edc.spi.monitor.Monitor; import org.json.JSONObject; +import java.io.IOException; import java.util.List; -public class LogMessageSender implements MultipartSenderDelegate { +public class LogMessageSender implements MultipartSenderDelegate { Monitor monitor; String connectorId; @@ -70,8 +72,8 @@ public String buildMessagePayload(LogMessage logMessage) { } @Override - public MultipartResponse getResponseContent(IdsMultipartParts parts) throws Exception { - return ResponseUtil.parseMultipartStringResponse(parts, JsonLd.getObjectMapper()); + public MultipartResponse getResponseContent(IdsMultipartParts parts) throws Exception { + return parseLogMessageReceiptResponse(parts, JsonLd.getObjectMapper()); } @Override @@ -132,4 +134,15 @@ private String buildTransferProcessPayload(TransferProcess transferProcess) { return jo.toString(); } + + public static MultipartResponse parseLogMessageReceiptResponse(IdsMultipartParts parts, ObjectMapper objectMapper) throws IOException { + var header = objectMapper.readValue(parts.getHeader(), Message.class); + + LogMessageReceipt payload = null; + if (parts.getPayload() != null) { + payload = objectMapper.readValue(parts.getPayload(), LogMessageReceipt.class); + } + + return new MultipartResponse<>(header, payload); + } } \ No newline at end of file diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java index 095e18d..73dec04 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java @@ -74,7 +74,6 @@ public void save(LoggingHouseMessage event) { event.getProcessId(), event.getConsumerId(), event.getProviderId(), - event.getStatus().getCode(), mapFromZonedDateTime(event.getCreatedAt()) ); diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java index e691e63..edd102e 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/worker/MessageWorker.java @@ -16,6 +16,7 @@ import com.truzzt.extension.logginghouse.client.events.messages.CreateProcessMessage; import com.truzzt.extension.logginghouse.client.events.messages.LogMessage; +import com.truzzt.extension.logginghouse.client.events.messages.LogMessageReceipt; import com.truzzt.extension.logginghouse.client.spi.store.LoggingHouseMessageStore; import com.truzzt.extension.logginghouse.client.spi.types.LoggingHouseMessage; import org.eclipse.edc.spi.EdcException; @@ -78,7 +79,7 @@ public void process(LoggingHouseMessage message) { createProcess(message, extendedProcessUrl).join(); } catch (Exception e) { // TODO: Not fail when process already exists - monitor.severe("CreateProcess returned error: " + e.getMessage()); + monitor.warning("CreateProcess returned error (ignore it when the process already exists): " + e.getMessage()); //throw new EdcException("Could not create process in LoggingHouse", e); } } @@ -89,7 +90,7 @@ public void process(LoggingHouseMessage message) { var response = logMessage(message, extendedLogUrl).join(); response.onSuccess(msg -> { monitor.info("Received receipt successfully from LoggingHouse for message with id " + message.getEventId()); - store.updateSent(message.getId(), msg); + store.updateSent(message.getId(), msg.data()); }); } catch (Exception e) { throw new EdcException("Could not log message to LoggingHouse", e); @@ -111,12 +112,12 @@ public CompletableFuture> createProcess(LoggingHouseMessage return dispatcherRegistry.dispatch(Object.class, logMessage); } - public CompletableFuture> logMessage(LoggingHouseMessage message, URL clearingHouseLogUrl) { + public CompletableFuture> logMessage(LoggingHouseMessage message, URL clearingHouseLogUrl) { monitor.info("Logging message to LoggingHouse with type " + message.getEventType() + " and id " + message.getEventId()); var logMessage = new LogMessage(clearingHouseLogUrl, connectorBaseUrl, message.getEventToLog()); - return dispatcherRegistry.dispatch(String.class, logMessage); + return dispatcherRegistry.dispatch(LogMessageReceipt.class, logMessage); } } From 88ada14334c37665367bf55403964114228fbfc6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Sch=C3=B6nenberg?= Date: Thu, 4 Jul 2024 12:38:56 +0200 Subject: [PATCH 5/7] fix: disabled state --- .../logginghouse/client/LoggingHouseClientExtension.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/LoggingHouseClientExtension.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/LoggingHouseClientExtension.java index b5c8e8b..2e815bd 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/LoggingHouseClientExtension.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/LoggingHouseClientExtension.java @@ -275,9 +275,8 @@ public void start() { monitor.info("Skipping start of Logginghouse client extension (disabled)."); } else { monitor.info("Starting Logginghouse client extension."); + workersManager.execute(); } - - workersManager.execute(); } @Override From e2e718706f2acac36dc7bddd9528dcb555e59d57 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Sch=C3=B6nenberg?= Date: Thu, 4 Jul 2024 13:34:39 +0200 Subject: [PATCH 6/7] fix: remove not null constraint for TransferProcess --- .../client/store/sql/SqlLoggingHouseMessageStore.java | 2 -- .../migration/logginghouse/V0_0_3__Remove_Constraint.sql | 3 +++ 2 files changed, 3 insertions(+), 2 deletions(-) create mode 100644 logging-house-client/src/main/resources/migration/logginghouse/V0_0_3__Remove_Constraint.sql diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java index 73dec04..d61dd52 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/store/sql/SqlLoggingHouseMessageStore.java @@ -61,7 +61,6 @@ public void save(LoggingHouseMessage event) { Objects.requireNonNull(event.getEventToLog()); Objects.requireNonNull(event.getCreateProcess()); Objects.requireNonNull(event.getProcessId()); - Objects.requireNonNull(event.getStatus()); Objects.requireNonNull(event.getCreatedAt()); transactionContext.execute(() -> { @@ -122,7 +121,6 @@ private ZonedDateTime mapToZonedDateTime(ResultSet resultSet, String column) thr } private LoggingHouseMessage mapResultSet(ResultSet resultSet) throws Exception { - Class eventType = toClass(resultSet.getString(statements.getEventTypeColumn())); Object eventToLog; diff --git a/logging-house-client/src/main/resources/migration/logginghouse/V0_0_3__Remove_Constraint.sql b/logging-house-client/src/main/resources/migration/logginghouse/V0_0_3__Remove_Constraint.sql new file mode 100644 index 0000000..080eabe --- /dev/null +++ b/logging-house-client/src/main/resources/migration/logginghouse/V0_0_3__Remove_Constraint.sql @@ -0,0 +1,3 @@ +ALTER TABLE edc_logging_house_message + ALTER COLUMN consumer_id DROP NOT NULL, + ALTER COLUMN provider_id DROP NOT NULL; \ No newline at end of file From dd3dd100c632a0c00f45b53ed35660a503c430ae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Sch=C3=B6nenberg?= Date: Thu, 4 Jul 2024 14:00:25 +0200 Subject: [PATCH 7/7] fix: checkstyle warnings --- .../logginghouse/client/events/messages/LogMessageReceipt.java | 2 +- .../logginghouse/client/events/messages/LogMessageSender.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java index f4c3457..4e43eda 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageReceipt.java @@ -1,3 +1,3 @@ package com.truzzt.extension.logginghouse.client.events.messages; -public record LogMessageReceipt (String data) {} +public record LogMessageReceipt(String data) {} diff --git a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java index 50af211..ab9d575 100644 --- a/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java +++ b/logging-house-client/src/main/java/com/truzzt/extension/logginghouse/client/events/messages/LogMessageSender.java @@ -21,7 +21,6 @@ import com.truzzt.extension.logginghouse.client.multipart.ids.multipart.IdsMultipartParts; import com.truzzt.extension.logginghouse.client.multipart.ids.multipart.MultipartResponse; import com.truzzt.extension.logginghouse.client.multipart.ids.multipart.MultipartSenderDelegate; -import com.truzzt.extension.logginghouse.client.multipart.ids.multipart.ResponseUtil; import de.fraunhofer.iais.eis.DynamicAttributeToken; import de.fraunhofer.iais.eis.LogMessageBuilder; import de.fraunhofer.iais.eis.Message;