-

lib/rabbit_async.pm

@@ -221,7 +221,7 @@ sub ack
   my $m = shift;
   
   $self->{channel}->ack(
-    delivery_tag => $m->{deliver}->{method_frame}->{delivery_tag},
+    delivery_tag => $m->{message}->{deliver}->{method_frame}->{delivery_tag},
   );
 }
 
@@ -231,7 +231,7 @@ sub reject
   my $m = shift;
   
   $self->{channel}->reject(
-    delivery_tag => $m->{deliver}->{method_frame}->{delivery_tag},
+    delivery_tag => $m->{message}->{deliver}->{method_frame}->{delivery_tag},
     requeue => 0,
   );
 }