From d19a76677ad61ec9f046ed868a105b690e7e4db6 Mon Sep 17 00:00:00 2001
From: Pedro Melo <melo@simplicidade.org>
Date: Sun, 20 Jul 2014 22:13:40 +0100
Subject: [PATCH] Add publish() to Connection, mapped to PUB command

Signed-off-by: Pedro Melo <melo@simplicidade.org>
---
 lib/AnyEvent/NSQ/Connection.pm | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/lib/AnyEvent/NSQ/Connection.pm b/lib/AnyEvent/NSQ/Connection.pm
index e483e2a..347f451 100644
--- a/lib/AnyEvent/NSQ/Connection.pm
+++ b/lib/AnyEvent/NSQ/Connection.pm
@@ -129,6 +129,20 @@ sub subscribe {
   return;
 }
 
+sub publish {
+  my ($self, $topic, $data, $cb) = @_;
+  return unless my $hdl = $self->{handle};
+
+  $cb = sub { }
+    unless $cb;
+
+  $hdl->push_write("PUB $topic\012" . pack('N', length($data)) . $data);
+
+  $self->_on_next_success_frame($cb);
+
+  return;
+}
+
 sub ready {
   my ($self, $n) = @_;
   return unless my $hdl = $self->{handle};