diff --git a/build.gradle.kts b/build.gradle.kts index b1d9b3e..b05def5 100644 --- a/build.gradle.kts +++ b/build.gradle.kts @@ -62,7 +62,7 @@ subprojects { maven { name = "GitHubPackages" url = uri("https://maven.pkg.github.com/truzzt/mds-ap3") - version = "0.2.2" + version = "0.2.3" credentials { username = System.getenv("USERNAME") password = System.getenv("TOKEN") 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 618a663..f4d535b 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 @@ -118,6 +118,8 @@ private URL readUrlFromSettings(ServiceExtensionContext context) { } private void registerEventSubscriber(ServiceExtensionContext context) { + monitor.debug("Registering event subscriber for LoggingHouseClientExtension"); + var eventSubscriber = new IdsClearingHouseServiceImpl( dispatcherRegistry, hostname, @@ -129,21 +131,33 @@ private void registerEventSubscriber(ServiceExtensionContext context) { eventRouter.registerSync(ContractNegotiationFinalized.class, eventSubscriber); eventRouter.registerSync(TransferProcessTerminated.class, eventSubscriber); context.registerService(IdsClearingHouseServiceImpl.class, eventSubscriber); + + monitor.debug("Registered event subscriber for LoggingHouseClientExtension"); } private void registerSerializerClearingHouseMessages(ServiceExtensionContext context) { + monitor.debug("Registering serializers for LoggingHouseClientExtension"); + typeManager.registerContext(TYPE_MANAGER_SERIALIZER_KEY, JsonLd.getObjectMapper()); registerCommonTypes(typeManager); + + monitor.debug("Registered serializers for LoggingHouseClientExtension"); } private void registerCommonTypes(TypeManager typeManager) { + monitor.debug("Registering serializers for LoggingHouseClientExtension"); + typeManager.registerSerializer(TYPE_MANAGER_SERIALIZER_KEY, LogMessage.class, new MultiContextJsonLdSerializer<>(LogMessage.class, CONTEXT_MAP)); typeManager.registerSerializer(TYPE_MANAGER_SERIALIZER_KEY, CreateProcessMessage.class, new MultiContextJsonLdSerializer<>(CreateProcessMessage.class, CONTEXT_MAP)); + + monitor.debug("Registered serializers for LoggingHouseClientExtension"); } private void registerClearingHouseMessageSenders(ServiceExtensionContext context) { + monitor.debug("Registering message senders for LoggingHouseClientExtension"); + var httpClient = context.getService(EdcHttpClient.class); var monitor = context.getMonitor(); var objectMapper = typeManager.getMapper(TYPE_MANAGER_SERIALIZER_KEY);