fixed for review

read_queue.go

@@ -5,7 +5,6 @@ import (
 	"encoding/json"
 	"fmt"
 	"github.com/streadway/amqp"
-	"piper/wpqueue"
 	"sync"
 )
 
@@ -130,7 +129,7 @@ func (rq *ReadQueue) Run() error {
 		return fmt.Errorf("[Rq][%s][Run]: %s", rq.queue, err)
 	}
 	wg.Add(1)
-	pool := wpqueue.NewWorkerPool(rq.routines, rq.queue, deliveries)
+	pool := NewWorkerPool(rq.routines, rq.queue, deliveries)
 	go pool.RunWorkerPool()
 
 	go func() {

types.go

@@ -1,5 +1,7 @@
 package piper
 
+import "github.com/streadway/amqp"
+
 type Message struct {
 	UID     string `json:"uid"`
 	Payload any    `json:"payload"`
@@ -25,3 +27,15 @@ type Report struct {
 	Reject *RejectReport `json:"reject,omitempty"`
 	Fail   *FailReport   `json:"fail,omitempty"`
 }
+
+type QueueWorkerPool struct {
+	workersCount int
+	queue        string
+	deliveries   <-chan amqp.Delivery
+	results      chan ResultDelivery
+}
+
+type ResultDelivery struct {
+	WorkerId int
+	Delivery amqp.Delivery
+}

wpqueue/wp.go → wp_queue.go

@@ -1,4 +1,4 @@
-package wpqueue
+package piper
 
 import (
 	"fmt"