diff --git a/lib/AnyEvent/NSQ/Reader.pm b/lib/AnyEvent/NSQ/Reader.pm index 76d7068..4e0dec1 100644 --- a/lib/AnyEvent/NSQ/Reader.pm +++ b/lib/AnyEvent/NSQ/Reader.pm @@ -61,8 +61,7 @@ sub _identified { $self->{routing}->{$msg->{message_id}} = $conn; weaken( $self->{routing}->{$msg->{message_id}} ); - my $action = $self->{message_cb}->($self, $msg); - + $self->{message_cb}->($self, $msg); } );