From 88b263f0d581850efee5f0d4cd72eafda3ee99eb Mon Sep 17 00:00:00 2001 From: Pedro Melo Date: Sun, 20 Jul 2014 17:45:30 +0100 Subject: [PATCH] Tidy identify, single write with all the data Signed-off-by: Pedro Melo --- lib/AnyEvent/NSQ/Connection.pm | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/lib/AnyEvent/NSQ/Connection.pm b/lib/AnyEvent/NSQ/Connection.pm index 407f4f2..3bff788 100644 --- a/lib/AnyEvent/NSQ/Connection.pm +++ b/lib/AnyEvent/NSQ/Connection.pm @@ -86,13 +86,12 @@ sub connect { sub identify { my ($self, @rest) = @_; - my $cb = pop @rest; return unless my $hdl = $self->{handle}; + my $cb = pop @rest; + my $data = JSON::XS::encode_json($self->_build_identity_payload(@rest)); - $hdl->push_write("IDENTIFY\012"); - $hdl->push_write(pack('N', length($data))); - $hdl->push_write($data); + $hdl->push_write("IDENTIFY\012" . pack('N', length($data)) . $data); $self->_on_next_success_frame(sub { $cb->($self, $self->{identify_info} = $_[1]) });