diff options
Diffstat (limited to 'src/payload-processor/processor/processor.go')
| -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 |