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};