Skip to content

Commit

Permalink
Rust: messages, fix DataProducerSendNotification
Browse files Browse the repository at this point in the history
  • Loading branch information
jmillan committed Oct 10, 2023
1 parent 7e5c18a commit 0a41ef6
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion rust/src/messages.rs
Original file line number Diff line number Diff line change
Expand Up @@ -2849,7 +2849,8 @@ impl Notification for DataProducerSendNotification {
Some(notification_body),
);
let message_body = message::Body::create_notification(&mut builder, notification);
let message = message::Message::create(&mut builder, message::Type::Request, message_body);
let message =
message::Message::create(&mut builder, message::Type::Notification, message_body);

builder.finish(message, None).to_vec()
}
Expand Down

0 comments on commit 0a41ef6

Please sign in to comment.