Skip to content

Commit 31cf45d

Browse files
committed
fix: use continue for payload errors + &str params
1 parent 8cef464 commit 31cf45d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/cli/republish_message.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ pub async fn republish_message(
7878
Some(Ok(s)) => s,
7979
Some(Err(e)) => {
8080
warn!("Error while deserializing message payload: {:?}", e);
81-
""
81+
continue;
8282
}
8383
};
8484

@@ -189,8 +189,8 @@ fn read_payload_from_file(path: &Path) -> Result<serde_json::Value, anyhow::Erro
189189
/// Display diff when payload is being changed
190190
fn display_diff_and_plan(
191191
dlq_message: &DlqMessage,
192-
old_payload: &String,
193-
new_payload: &String,
192+
old_payload: &str,
193+
new_payload: &str,
194194
dlq_topic: &str,
195195
payload_file: &Path,
196196
dry_run: bool,

0 commit comments

Comments
 (0)