队列消费者监听器

/**
 * 队列消费者监听器
 */
public class QueueConsumerListener implements MessageListener {

    private static final Logger logger = LoggerFactory.getLogger(QueueConsumerListener.class);

    @Override
    public void onMessage(Message message) {
        try {
            // 消息处理逻辑
            logger.info("接收到消息：{}", message.toString());
        } catch (Exception e) {
            logger.error("消息处理异常：{}", e.getMessage());
        }
    }
}