diff --git a/pubsub/pubsub.go b/pubsub/pubsub.go
index 54a4b8ae..28e008ca 100644
--- a/pubsub/pubsub.go
+++ b/pubsub/pubsub.go
@@ -209,6 +209,11 @@ func (s *Server) OnStart() error {
 	return nil
 }
 
+// OnReset implements Service.OnReset
+func (s *Server) OnReset() error {
+	return nil
+}
+
 func (s *Server) loop(state state) {
 loop:
 	for cmd := range s.cmds {