Refactored the RocketMQ bridge to avoid leaking resources during crashes at creation.