diff options
| -rw-r--r-- | src/payload-processor/processor/processor.go | 6 | ||||
| -rw-r--r-- | src/rest-api/handler/handler.go | 6 |
2 files changed, 6 insertions, 6 deletions
diff --git a/src/payload-processor/processor/processor.go b/src/payload-processor/processor/processor.go index 9cd83f9..3eb089b 100644 --- a/src/payload-processor/processor/processor.go +++ b/src/payload-processor/processor/processor.go @@ -11,15 +11,15 @@ type Processor struct { queueName string } -func NewProcessor(ch *amqp.Channel, queueName string) *Processor { +func NewProcessor(ch *amqp.Channel, queueName string) Processor { log.Println("Created processor") - return &Processor{ + return Processor{ ch: ch, queueName: queueName, } } -func (p *Processor) ProcessMessages() { +func (p Processor) ProcessMessages() { msgs, err := p.ch.Consume( p.queueName, // queue "", // consumer diff --git a/src/rest-api/handler/handler.go b/src/rest-api/handler/handler.go index c904ff4..b9bb80e 100644 --- a/src/rest-api/handler/handler.go +++ b/src/rest-api/handler/handler.go @@ -16,14 +16,14 @@ type Handler struct { queueName string } -func NewHandler(ch *amqp.Channel, queueName string) *Handler { - return &Handler{ +func NewHandler(ch *amqp.Channel, queueName string) Handler { + return Handler{ ch: ch, queueName: queueName, } } -func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) { +func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) { bytes, err := io.ReadAll(io.Reader(r.Body)) if err != nil { log.Fatal(err) |