Refactor: change package name

Author: asheswook

internal/queue/kafka/operator.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"errors"
 	"github.com/IBM/sarama"
-	"github.com/violetpay-org/new-queue-manager/queue"
+	"github.com/violetpay-org/event-queue/queue"
 )
 
 type ConsumeOperator[Msg any] struct {

internal/queue/kafka/operator_test.go

@@ -2,7 +2,7 @@ package kafkaqueue
 
 import (
 	"github.com/IBM/sarama"
-	"github.com/violetpay-org/new-queue-manager/queue"
+	"github.com/violetpay-org/event-queue/queue"
 	"testing"
 )
 

queue/kafka/operator.go

@@ -2,8 +2,8 @@ package kafkaqueue
 
 import (
 	"github.com/IBM/sarama"
-	kafkaqueue "github.com/violetpay-org/new-queue-manager/internal/queue/kafka"
-	"github.com/violetpay-org/new-queue-manager/queue"
+	kafkaqueue "github.com/violetpay-org/event-queue/internal/queue/kafka"
+	"github.com/violetpay-org/event-queue/queue"
 )
 
 func NewConsumeOperator[Msg any](serializer queue.MessageSerializer[*sarama.ConsumerMessage, Msg], callback queue.Callback[Msg], brokers []string, topic string, groupId string, config *sarama.Config) *kafkaqueue.ConsumeOperator[Msg] {

queue/serializer_test.go

@@ -3,7 +3,7 @@ package queue_test
 import (
 	"github.com/IBM/sarama"
 	"github.com/stretchr/testify/assert"
-	"github.com/violetpay-org/new-queue-manager/queue"
+	"github.com/violetpay-org/event-queue/queue"
 	"testing"
 )