diff --git a/lib/AnyEvent/NSQ/Reader.pm b/lib/AnyEvent/NSQ/Reader.pm index 833f5d7..9076e91 100644 --- a/lib/AnyEvent/NSQ/Reader.pm +++ b/lib/AnyEvent/NSQ/Reader.pm @@ -35,6 +35,8 @@ sub _parse_args { sub _identified { my ($self, $conn, $info) = @_; + $self->SUPER::_identified(@_); + $conn->subscribe( $self->{topic}, $self->{channel},