Enterprise integration

IBM MQ ──> Spring service ──POST /v1/flows/classify-error/run──> Milford ──> model or classifier
              │  (JMS, transactions,                               (stateless)
              │   history lookup, storage)
              └──> writes the new error to its own database

curl -s localhost:8080/v1/flows/classify-error/run \
  -H "authorization: Bearer $MILFORD_TOKEN" \
  -H "idempotency-key: ID:414d51204d5152...-1" \
  -d '{"input": {
    "service": "payments",
    "message": "Connection refused: db-primary:5432",
    "stackTrace": "",
    "history": ["Connection refused: db-primary:5432"]
  }}'

@Component
class MilfordClient {
    private final RestClient http;

    MilfordClient(@Value("${milford.url}") String url, @Value("${milford.token}") String token) {
        var factory = new JdkClientHttpRequestFactory();
        factory.setReadTimeout(Duration.ofSeconds(40)); // longer than run.timeoutMs
        this.http = RestClient.builder()
            .baseUrl(url)
            .requestFactory(factory)
            .defaultHeader(HttpHeaders.AUTHORIZATION, "Bearer " + token)
            .build();
    }

    JsonNode run(String flow, Map<String, Object> input, String idempotencyKey) {
        return http.post()
            .uri("/v1/flows/{id}/run", flow)
            .header("Idempotency-Key", idempotencyKey)
            .body(Map.of("input", input))
            .retrieve()
            .body(JsonNode.class);
    }
}

@JmsListener(destination = "ERRORS.IN")
void onError(TextMessage message) throws JMSException {
    var error = parse(message.getText());
    var result = milford.run("classify-error", Map.of(
        "service", error.service(),
        "message", error.message(),
        "stackTrace", error.stackTrace(),
        "history", history.similarTo(error)), message.getJMSMessageID());

    if (!result.path("ok").asBoolean()) throw new IllegalStateException("classification failed");
    var data = result.path("output").path("data");
    // ... write the error, or link it to an existing one, using data.path("duplicate").path("noul")
}