Infra It Mq Generator

• {{infraModuleDir}}/src/test/java/.../event/mq/<Xxx>IT.java
• Optional shared test supports (BaseIntegrationTest, AwaitilitySupport) if absent.

Naming & Packaging

• *IT suffix mandatory.
• Package under infra/event/mq/**.

Implementation Rules

• Use Testcontainers Kafka via shared base class and @ServiceConnection.
• Ensure topic exists before publish (AdminClient idempotent create/check).
• Use Awaitility for eventual assertions; do not use Thread.sleep as primary assertion.
• Prefer asserting observable outcomes (inbox row count/status, dedup behavior).
• Keep DB operations in IT aligned with infra data access conventions (mapper/store).

Template Blueprint

1. Integration Surface

• Kafka broker via Testcontainers.
• MQ transport/producer/consumer component under test.
• Optional persistence side (inbox/outbox/store) for eventual consistency assertions.

2. Required Annotations

• Use the project's infra integration-test context annotation/style.
• Ensure Kafka container connection is injected into test runtime (for example via @ServiceConnection).

3. Code Flow

• Arrange: create/ensure topic, prepare test message with deterministic key/idempotency fields.
• Act: publish or consume through infra boundary API.
• Assert: verify observable outcomes (message handling result, persistence state, dedup/final consistency) with Awaitility polling.
• Cleanup: clear test-owned records/messages and reset listener state if needed.

Tests

• IT-only gate:
  • mvn -pl persimmon-scaffold/persimmon-scaffold-infra -Pit clean verify
  • -Pit means Maven -P it (profile id is it).

Common Mistakes

Integration

• Called by: scaffold-router, infra-integration-test-generator
• Pairs with: infra-mq-transport-generator, app-common-event-generator

Phase Commit Gate

• mvn -pl persimmon-scaffold/persimmon-scaffold-infra clean test
• mvn -pl persimmon-scaffold/persimmon-scaffold-infra -Pit clean verify