You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I have confirmed that this should be classified as an enhancement rather than a bug/feature.
Summary
ConsumeMessageConcurrentlyService#submitConsumeRequest code should be more concise.
Because the consumeExecutor uses a LinkedBlockingQueue, so as with ConsumeMessageConcurrentlyService#submitConsumeRequestLater , exception catching is unnecessary.
The code for submitting messages to the consumer in batches should be more concise.
Before Creating the Enhancement Request
Summary
ConsumeMessageConcurrentlyService#submitConsumeRequest code should be more concise.
rocketmq/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
Lines 187 to 223 in b37d283
rocketmq/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
Lines 346 to 356 in b37d283
Motivation
.
Describe the Solution You'd Like
I will optimise the submitConsumeRequest and remove unnecessary exception catching.
Describe Alternatives You've Considered
.
Additional Context
No response
The text was updated successfully, but these errors were encountered: