package jnpf.limsService.support;
|
|
import java.nio.charset.StandardCharsets;
|
import java.nio.file.Files;
|
import java.nio.file.Path;
|
import java.nio.file.Paths;
|
|
/** Source-level wiring probe for the transaction-bound water sampling message. */
|
public class LimsWaterSamplingMessageWiringChecks {
|
public static void main(String[] args) throws Exception {
|
String service = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/impl/"
|
+ "LimsSxtQuyangJihuaRenwuServiceImpl.java");
|
int generated = service.indexOf("renwuMapper.markGenerated(");
|
int published = service.indexOf("eventPublisher.publishEvent(new LimsWaterSamplingMessageEvent(");
|
require(generated >= 0 && published > generated,
|
"message event must be published after the task is marked generated");
|
|
String listener = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/listener/"
|
+ "LimsWaterSamplingMessageListener.java");
|
require(listener.contains("TransactionPhase.AFTER_COMMIT"), "listener must run after commit");
|
require(listener.contains("LimsRecipientRef.role(event.getSamplingRoleId())"),
|
"sampling role must be resolved explicitly as ROLE");
|
require(listener.contains("LimsMessageEvent.WATER_SAMPLING_DUE"), "fixed event code is required");
|
|
String ledger = read("jnpf-lims/jnpf-lims-biz/src/main/java/jnpf/limsService/impl/"
|
+ "LimsMessageLedgerService.java");
|
require(ledger.contains("Propagation.REQUIRES_NEW"),
|
"after-commit message ledger must use an independent transaction");
|
}
|
|
private static String read(String path) throws Exception {
|
Path root = Paths.get(System.getProperty("user.dir"));
|
return new String(Files.readAllBytes(root.resolve(path)), StandardCharsets.UTF_8);
|
}
|
|
private static void require(boolean value, String message) {
|
if (!value) {
|
throw new AssertionError(message);
|
}
|
}
|
}
|
