diff --git a/transport/redis_pubsub/publisher.go b/transport/redis_pubsub/publisher.go
index 599ba1c..1625ab8 100644
--- a/transport/redis_pubsub/publisher.go
+++ b/transport/redis_pubsub/publisher.go
@@ -31,3 +31,7 @@ func (r *Publisher) Flush() error {
 	_, err := r.pipeline.Exec(r.ctx)
 	return err
 }
+
+func (r *Publisher) Close() error {
+	return r.pipeline.Close()
+}