Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions rocketmq-broker/src/schedule/schedule_message_service.rs
Original file line number Diff line number Diff line change
Expand Up @@ -844,12 +844,12 @@

/// Process for handling the result of putting a message
pub struct PutResultProcess<MS> {
topic: String,
topic: CheetahString,
offset: i64,
physic_offset: i64,
physic_size: i32,
delay_level: i32,
msg_id: String,
msg_id: CheetahString,
auto_resend: bool,
future: Option<oneshot::Receiver<PutMessageResult>>,
result_sender: Option<oneshot::Sender<PutMessageResult>>,
Expand All @@ -864,12 +864,12 @@
pub fn new(broker_controller: ArcMut<BrokerRuntimeInner<MS>>) -> Self {
let (tx, rx) = oneshot::channel();
Self {
topic: String::new(),
topic: CheetahString::empty(),

Check warning on line 867 in rocketmq-broker/src/schedule/schedule_message_service.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/schedule/schedule_message_service.rs#L867

Added line #L867 was not covered by tests
offset: 0,
physic_offset: 0,
physic_size: 0,
delay_level: 0,
msg_id: String::new(),
msg_id: CheetahString::empty(),

Check warning on line 872 in rocketmq-broker/src/schedule/schedule_message_service.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/schedule/schedule_message_service.rs#L872

Added line #L872 was not covered by tests
auto_resend: false,
future: Some(rx),
result_sender: Some(tx),
Expand All @@ -880,7 +880,7 @@
}

/// Set the topic for this process
pub fn set_topic(mut self, topic: impl Into<String>) -> Self {
pub fn set_topic(mut self, topic: impl Into<CheetahString>) -> Self {

Check warning on line 883 in rocketmq-broker/src/schedule/schedule_message_service.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/schedule/schedule_message_service.rs#L883

Added line #L883 was not covered by tests
self.topic = topic.into();
self
}
Expand Down Expand Up @@ -910,7 +910,7 @@
}

/// Set the message ID for this process
pub fn set_msg_id(mut self, msg_id: impl Into<String>) -> Self {
pub fn set_msg_id(mut self, msg_id: impl Into<CheetahString>) -> Self {

Check warning on line 913 in rocketmq-broker/src/schedule/schedule_message_service.rs

View check run for this annotation

Codecov / codecov/patch

rocketmq-broker/src/schedule/schedule_message_service.rs#L913

Added line #L913 was not covered by tests
self.msg_id = msg_id.into();
self
}
Expand Down
Loading