diff --git a/lib/AnyEvent/NSQ/Client.pm b/lib/AnyEvent/NSQ/Client.pm
index f5c9852..6182760 100644
--- a/lib/AnyEvent/NSQ/Client.pm
+++ b/lib/AnyEvent/NSQ/Client.pm
@@ -57,6 +57,9 @@ 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 { };
+
   for my $arg (qw( client_id hostname connect_timeout )) {
     $self->{$arg} = delete($args->{$arg}) if exists $args->{$arg};
   }