scrow/scrow-monorepo
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 2 Wiki Activity Actions

a

Browse source
This commit is contained in:
kento2 2026-07-07 13:55:39 +02:00
parent be248bfea9
commit d9baa4113e
3 changed files with 15 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

8
core-lib/src/main/java/de/kentoj/scrowlib/messaging/MessageBroker.java
View file

@ -6,6 +6,7 @@ import io.nats.client.Dispatcher;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.bson.Document; import org.bson.Document;
import java.util.Optional;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.function.Consumer; import java.util.function.Consumer;
@ -73,4 +74,11 @@ public class MessageBroker {
var response = nats.request(subject, DocumentRepository.toBytes(document)).join(); var response = nats.request(subject, DocumentRepository.toBytes(document)).join();
return ResultRepository.fromDocument(DocumentRepository.fromMessage(response)); return ResultRepository.fromDocument(DocumentRepository.fromMessage(response));
} }
public static <S> S unwrap(Result<S, String> result, String message) {
Optional<String> err = result.getFailure();
if (err.isPresent())
throw new RuntimeException(message + ": " + err.orElseThrow());
return result.getSuccess().orElseThrow();
}
} }

7
core-lib/src/main/java/de/kentoj/scrowlib/messaging/RemoteException.java Normal file
View file

@ -0,0 +1,7 @@
package de.kentoj.scrowlib.messaging;
public class RemoteException extends RuntimeException {
public RemoteException(String message) {
super(message);
}
}

6
core-lib/src/main/java/de/kentoj/scrowlib/utils/ResultUtils.java
View file

@ -8,10 +8,4 @@ import java.util.Optional;
@NoArgsConstructor(access = AccessLevel.NONE) @NoArgsConstructor(access = AccessLevel.NONE)
public class ResultUtils { public class ResultUtils {
public static <S> S unwrap(Result<S, String> result, String message) {
Optional<String> err = result.getFailure();
if (err.isPresent())
throw new RuntimeException(message + ": " + err.orElseThrow());
return result.getSuccess().orElseThrow();
}
} }