How is multi-tenancy managed during message consumption?

The pattern requires capturing the tenantId in the message object (PO) during sending and programmatically setting the TenantContextHolder during consumption in the Handler.

How does this skill handle message serialization?

The skill enforces the use of JacksonUtil to serialize message payloads into Strings before transmission, ensuring compatibility with the project's underlying MqUtil framework.

What is the importance of sendByTxEnd in this pattern?

It ensures that messages are only sent to the queue after the database transaction has successfully committed, preventing 'phantom' messages if a transaction rolls back.

Why is the @Lazy annotation used in MQ Listeners?

The @Lazy annotation is required on Handler injections within Listeners to prevent circular dependency errors during the Spring application context initialization.

Leniu Java MQ Pattern

Name: Leniu Java MQ Pattern
Author: xu-cell

byxu-cell

•

API Development

Implements standardized message queue patterns for Leniu Java projects including transactional and delayed messaging logic.

The leniu-java-mq skill provides a robust architectural framework for implementing Message Queue (MQ) functionality within the leniu-tengyun-core and leniu-yunshitang ecosystems. It enforces a standardized three-layer architecture—consisting of static Message Senders, MQ Listeners, and Business Handlers—to ensure reliable asynchronous processing. The skill specifically addresses complex requirements such as database-to-MQ transactional consistency, scheduled delayed messages, and the automatic propagation of multi-tenant and trace ID contexts across distributed threads. By following these domain-specific patterns, developers can prevent common issues like circular dependencies and serialization errors while maintaining high code quality and observability.

Key Features

0111 GitHub stars

02Standardized JacksonUtil serialization patterns

03Automatic tenant and trace ID context propagation

04Predefined delayed message durations using LeMqConstant

05Three-layer messaging architecture (Sender-Listener-Handler)

06Transactional message consistency via sendByTxEnd

Use Cases

01Synchronizing downstream notifications with database transactions to ensure data integrity

02Implementing order timeout mechanisms using standardized delayed message queues

03Decoupling complex business logic into asynchronous background tasks with Redisson locking

What are Skills?·How to Install

Install with 🐟 Skill.Fish

npx skillfish add xu-cell/ai-engineering-init leniu-java-mq

For use in Claude.ai and ChatGPT

Key Features

0111 GitHub stars

02Standardized JacksonUtil serialization patterns

03Automatic tenant and trace ID context propagation

04Predefined delayed message durations using LeMqConstant

05Three-layer messaging architecture (Sender-Listener-Handler)

06Transactional message consistency via sendByTxEnd

Use Cases

01Synchronizing downstream notifications with database transactions to ensure data integrity

02Implementing order timeout mechanisms using standardized delayed message queues

03Decoupling complex business logic into asynchronous background tasks with Redisson locking