diff --git a/lib/PiTube/Controller/Nginx.pm b/lib/PiTube/Controller/Nginx.pm
index 81237048b510eaa231a2f8acc101819ff350ed69..f84573d7134c0c3ea08ec1f5f106db21ecf4b500 100644
--- a/lib/PiTube/Controller/Nginx.pm
+++ b/lib/PiTube/Controller/Nginx.pm
@@ -1,10 +1,13 @@
 package PiTube::Controller::Nginx;
 use Mojo::Base 'Mojolicious::Controller';
+use Mojo::Pg::PubSub;
 
 use constant HLS => qr/hls\/([a-z0-9\-]+)(_\w+)?(\/\w+)?\.(m3u8|ts)$/i;
 
 sub callback_rtmp {
     my $c = shift;
+    my $pubsub = Mojo::Pg::PubSub->new(pg => $c->pg);
+    $pubsub = $pubsub->json('messages');
 
     if ( $c->param('call') =~ /publish/ ) {
         my $name = $c->param('name');
@@ -32,6 +35,11 @@ sub callback_rtmp {
             publish_last     => '\now()',
             publish_user_id  => $user->id,
             publish_time     => ( $c->param('time') // 0 ),
+            is_live          => ( $c->param('call') =~ /done/ ) ? 'f':'t',
+        });
+
+        $pubsub->notify( messages => {
+            call   => $c->param('call'),
         });
 
     }