Skip to content

Commit

Permalink
chore: add some logs
Browse files Browse the repository at this point in the history
  • Loading branch information
schoenenberg committed Feb 5, 2024
1 parent 81740c9 commit 63f5f73
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 1 deletion.
2 changes: 1 addition & 1 deletion build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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);
Expand Down

0 comments on commit 63f5f73

Please sign in to comment.