diff --git a/lib/AnyEvent/NSQ/Connection.pm b/lib/AnyEvent/NSQ/Connection.pm index b31f734..8ce7266 100644 --- a/lib/AnyEvent/NSQ/Connection.pm +++ b/lib/AnyEvent/NSQ/Connection.pm @@ -211,7 +211,7 @@ sub _disconnected { my ($self) = @_; $self->{handle}->destroy; - delete $self->{$_} for qw(conn connected); + delete $self->{$_} for qw(handle connected); } sub _force_disconnect {