diff --git a/lib/AnyEvent/NSQ/Client.pm b/lib/AnyEvent/NSQ/Client.pm index 19075d2..8fb3d09 100644 --- a/lib/AnyEvent/NSQ/Client.pm +++ b/lib/AnyEvent/NSQ/Client.pm @@ -47,6 +47,14 @@ sub publish { return $conn->publish($topic, @data); } +sub ready { + my ($self, $ready_count) = @_; + + $_->{conn}->ready($ready_count) for values %{ $self->{nsqd_conns} }; + + return; +} + #### Argument parsing