From 1f0042b10b64c7317fd9cda385a7447c95efe4a8 Mon Sep 17 00:00:00 2001 From: Bruno Tavares Date: Tue, 2 Sep 2014 18:19:20 +0100 Subject: [PATCH 1/2] FIX: Save the connection state callbacks --- lib/AnyEvent/NSQ/Client.pm | 3 +++ 1 file changed, 3 insertions(+) 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}; } From 7b89af5b974cd3fcdf9fa7b383b449b48f3cc197 Mon Sep 17 00:00:00 2001 From: Bruno Tavares Date: Tue, 2 Sep 2014 18:23:07 +0100 Subject: [PATCH 2/2] Identation --- lib/AnyEvent/NSQ/Client.pm | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/AnyEvent/NSQ/Client.pm b/lib/AnyEvent/NSQ/Client.pm index 6182760..19075d2 100644 --- a/lib/AnyEvent/NSQ/Client.pm +++ b/lib/AnyEvent/NSQ/Client.pm @@ -57,7 +57,7 @@ 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->{connect_cb} = delete($args->{connect_cb}) || sub { }; $self->{identify_cb} = delete($args->{identify_cb}) || sub { }; for my $arg (qw( client_id hostname connect_timeout )) {