diff --git a/lib/AnyEvent/NSQ/Client.pm b/lib/AnyEvent/NSQ/Client.pm index 8fb3d09..5d61374 100644 --- a/lib/AnyEvent/NSQ/Client.pm +++ b/lib/AnyEvent/NSQ/Client.pm @@ -65,8 +65,8 @@ sub _parse_args { $self->{disconnect_cb} = delete($args->{disconnect_cb}) || sub { }; $self->{error_cb} = delete($args->{error_cb}) || sub { croak($_[1]) }; - $self->{connect_cb} = delete($args->{connect_cb}) || sub { }; - $self->{identify_cb} = delete($args->{identify_cb}) || sub { }; + $self->{connect_cb} = delete($args->{connect_cb}) || sub { }; + $self->{identify_cb} = delete($args->{identify_cb}) || sub { }; for my $arg (qw( client_id hostname connect_timeout )) { $self->{$arg} = delete($args->{$arg}) if exists $args->{$arg};