Skip to content

Commit

Permalink
fix: typo delete message (#14)
Browse files Browse the repository at this point in the history
Co-authored-by: aspnxdd <arnau@omniatech.io>
  • Loading branch information
aspnxdd and aspnxdd authored Mar 19, 2023
1 parent 726e761 commit 094f75b
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/functions.rs
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ impl<T: ConnectionLike> RsmqFunctions<T> {

/// Returns a message. The message stays hidden for some time (defined by "seconds_hidden"
/// argument or the queue settings). After that time, the message will be redelivered.
/// In order to avoid the redelivery, you need to use the "dekete_message" after this function.
/// In order to avoid the redelivery, you need to use the "delete_message" after this function.
pub async fn receive_message<E: TryFrom<RedisBytes, Error = Vec<u8>>>(
&self,
conn: &mut T,
Expand Down
2 changes: 1 addition & 1 deletion src/trait.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ pub trait RsmqConnection {
qname: &str,
) -> RsmqResult<Option<RsmqMessage<E>>>;

/// Returns a message. The message stays hidden for some time (defined by "seconds_hidden" argument or the queue settings). After that time, the message will be redelivered. In order to avoid the redelivery, you need to use the "dekete_message" after this function.
/// Returns a message. The message stays hidden for some time (defined by "seconds_hidden" argument or the queue settings). After that time, the message will be redelivered. In order to avoid the redelivery, you need to use the "delete_message" after this function.
async fn receive_message<E: TryFrom<RedisBytes, Error = Vec<u8>>>(
&mut self,
qname: &str,
Expand Down

0 comments on commit 094f75b

Please sign in to comment.