Use when generating MQ integration tests (*IT) for infra transport/final-consistency using Kafka + Awaitility + inbox/outbox semantics.
Generates integration tests for Kafka-based MQ transport, verifying send/consume/persist final consistency with Awaitility polling and inbox/outbox semantics.
REQUIRED: Follow GENERATOR_SKILL_STRUCTURE.md. Variables in VARIABLES.md.
infra/event/mq/** integration tests.infra-it-db-generator.infra-it-http-generator.{{infraModuleDir}}/src/test/java/.../event/mq/<Xxx>IT.javaBaseIntegrationTest, AwaitilitySupport) if absent.*IT suffix mandatory.infra/event/mq/**.@ServiceConnection.Thread.sleep as primary assertion.@ServiceConnection).mvn -pl persimmon-scaffold/persimmon-scaffold-infra -Pit clean verify-Pit means Maven -P it (profile id is it).| Mistake | Why It Happens | Fix |
|---|---|---|
| Publishing before broker/topic is ready | Test races container startup | Use AdminClient idempotent create/check before publish |
| Listener config missing mapper/type-handler support | UUID and temporal fields not registered | Ensure type handlers are imported in test context |
| Infinite re-consume loops | Listener exceptions not handled in test setup | Add error handler or dead-letter config in test consumer setup |
scaffold-router, infra-integration-test-generatorinfra-mq-transport-generator, app-common-event-generatormvn -pl persimmon-scaffold/persimmon-scaffold-infra clean testmvn -pl persimmon-scaffold/persimmon-scaffold-infra -Pit clean verify