diff options
| author | Baitinq <[email protected]> | 2024-05-02 17:51:11 +0200 |
|---|---|---|
| committer | Baitinq <[email protected]> | 2024-05-02 17:51:11 +0200 |
| commit | d77a4faea818712b24edf9b27093c3b84b7ff85e (patch) | |
| tree | c638413818f8871a2decbb613e15b163d0a173ce /src/payload-processor/processor | |
| parent | payload-processor: add stub (diff) | |
| download | fs-tracer-backend-d77a4faea818712b24edf9b27093c3b84b7ff85e.tar.gz fs-tracer-backend-d77a4faea818712b24edf9b27093c3b84b7ff85e.tar.bz2 fs-tracer-backend-d77a4faea818712b24edf9b27093c3b84b7ff85e.zip | |
misc: clean up unnecessary use of ptrs
Diffstat (limited to 'src/payload-processor/processor')
| -rw-r--r-- | src/payload-processor/processor/processor.go | 6 |
1 files changed, 3 insertions, 3 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 |