diff --git a/ngx_rtmp_notify_module.c b/ngx_rtmp_notify_module.c
index ec84055..a3e1ce5 100644
--- a/ngx_rtmp_notify_module.c
+++ b/ngx_rtmp_notify_module.c
@@ -14,7 +14,7 @@
 
 static ngx_rtmp_publish_pt                      next_publish;
 static ngx_rtmp_play_pt                         next_play;
-static ngx_rtmp_delete_stream_pt                next_delete_stream;
+static ngx_rtmp_close_stream_pt                 next_close_stream;
 static ngx_rtmp_record_done_pt                  next_record_done;
 
 
@@ -780,8 +780,8 @@ next:
 
 
 static ngx_int_t
-ngx_rtmp_notify_delete_stream(ngx_rtmp_session_t *s,
-                              ngx_rtmp_delete_stream_t *v)
+ngx_rtmp_notify_close_stream(ngx_rtmp_session_t *s,
+                             ngx_rtmp_close_stream_t *v)
 {
     ngx_rtmp_notify_ctx_t          *ctx;
     ngx_rtmp_notify_app_conf_t     *nacf;
@@ -821,7 +821,7 @@ ngx_rtmp_notify_delete_stream(ngx_rtmp_session_t *s,
     ctx->flags = 0;
 
 next:
-    return next_delete_stream(s, v);
+    return next_close_stream(s, v);
 }
 
 
@@ -1003,8 +1003,8 @@ ngx_rtmp_notify_postconfiguration(ngx_conf_t *cf)
     next_play = ngx_rtmp_play;
     ngx_rtmp_play = ngx_rtmp_notify_play;
 
-    next_delete_stream = ngx_rtmp_delete_stream;
-    ngx_rtmp_delete_stream = ngx_rtmp_notify_delete_stream;
+    next_close_stream = ngx_rtmp_close_stream;
+    ngx_rtmp_close_stream = ngx_rtmp_notify_close_stream;
 
     next_record_done = ngx_rtmp_record_done;
     ngx_rtmp_record_done = ngx_rtmp_notify_record_done;