Skip to content

Commit

Permalink
[ISSUE #2323]🐛Fix PopMessageProcessor build SubscriptionData error🧑‍💻
Browse files Browse the repository at this point in the history
  • Loading branch information
mxsm committed Jan 18, 2025
1 parent c1334c5 commit 925e912
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions rocketmq-broker/src/processor/pop_message_processor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,7 @@ where
Ok(value) => value,
Err(_) => {
warn!(
"Parse the consumer's subscription[{}] error, group: {}",
"Parse the consumer's subscription[{:?}] error, group: {}",

Check warning on line 297 in rocketmq-broker/src/processor/pop_message_processor.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/processor/pop_message_processor.rs#L296-L297

Added lines #L296 - L297 were not covered by tests
request_header.exp, request_header.consumer_group
);
return Ok(Some(
Expand Down Expand Up @@ -327,7 +327,7 @@ where
Ok(value) => value,
Err(_) => {
warn!(
"Parse the consumer's subscription[{}] error, group: {}",
"Parse the consumer's subscription[{:?}] error, group: {}",

Check warning on line 330 in rocketmq-broker/src/processor/pop_message_processor.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/processor/pop_message_processor.rs#L329-L330

Added lines #L329 - L330 were not covered by tests
request_header.exp, request_header.consumer_group
);
return Ok(Some(
Expand Down

0 comments on commit 925e912

Please sign in to comment.