fix(consumer): fix panic when messages size is 0

[unJASON]

Fixes #1454

Modifications

Describe the modifications you've done.

if messages in MessageReceived are all skipped, then don't add into queuech.

avoid panic when dispatcher() received clear command from clearQueueCh

Verifying this change

• Make sure that the change passes the CI checks.

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

• Added integration tests for end-to-end deployment with large payloads (10MB)
• Extended integration test for recovery after broker failure

Does this pull request potentially affect one of the following parts:

If yes was chosen, please highlight the changes

• Dependencies (does it add or upgrade a dependency): no
• The public API: no
• The schema: don't know
• The default values of configurations: no
• The wire protocol: no

Documentation

• Does this pull request introduce a new feature? no
• If yes, how is the feature documented? (not applicable / docs / GoDocs / not documented)
• If a feature is not applicable for documentation, explain why?
• If a feature is not documented yet in this PR, please create a followup issue for adding the documentation

[Copilot]

Pull request overview

This pull request fixes a panic in the consumer when all messages in a batch are filtered/skipped, resulting in an empty message slice being sent to the dispatcher. The panic occurred in the dispatcher() function when trying to access the first element of an empty slice during queue clearing operations.

Changes:

• Added a check to prevent empty message slices from being sent to queueCh when all messages are filtered
• Added a warning log when all messages in a batch are filtered

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[RobertIndie]

Could you help add a test?

[unJASON]

I'm truly sorry, but I really don't have an ample amount of time at the moment. You see, it seems to me that the situation is quite evident. In fact, the modifications required are merely a few lines of code, which should be rather straightforward to rectify.

[unJASON]

I'm truly sorry, but I really don't have an ample amount of time at the moment. You see, it seems to me that the situation is quite evident. In fact, the modifications required are merely a few lines of code, which should be rather straightforward to rectify.

[crossoverJie]

I've added the relevant test cases.

[AssKicker0214]

that's really helpful @unJASON