diff options
Diffstat (limited to 'plugins/redis/pubsub.go')
| -rw-r--r-- | plugins/redis/pubsub.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/redis/pubsub.go b/plugins/redis/pubsub.go index 4e41acb5..01efc623 100644 --- a/plugins/redis/pubsub.go +++ b/plugins/redis/pubsub.go @@ -6,7 +6,7 @@ import ( "github.com/go-redis/redis/v8" "github.com/spiral/errors" - "github.com/spiral/roadrunner/v2/pkg/pubsub" + "github.com/spiral/roadrunner/v2/common/pubsub" "github.com/spiral/roadrunner/v2/plugins/config" "github.com/spiral/roadrunner/v2/plugins/logger" ) @@ -21,7 +21,7 @@ type PubSubDriver struct { stopCh chan struct{} } -func NewPubSubDriver(log logger.Logger, key string, cfgPlugin config.Configurer, stopCh chan struct{}) (pubsub.PubSub, error) { +func NewPubSubDriver(log logger.Logger, key string, cfgPlugin config.Configurer, stopCh chan struct{}) (*PubSubDriver, error) { const op = errors.Op("new_pub_sub_driver") ps := &PubSubDriver{ log: log, |