Skip to content

Commit

Permalink
Update
Browse files Browse the repository at this point in the history
  • Loading branch information
zarnoevic committed Feb 28, 2024
1 parent abda4b4 commit 7d962c9
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
1 change: 0 additions & 1 deletion src/cmd/server/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,6 @@ func main() {
fmt.Printf("Created consumer service %v\n", processor)

for msg := range msgs {
fmt.Printf("Processing message %v\n", msg)
processor.ProcessMessage(msg)
}
}
1 change: 0 additions & 1 deletion src/pkg/services/consumerService/consumerService.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ func NewConsumerService(omap *orderedmap.OrderedMap) *ConsumerService {
}

func (cs *ConsumerService) ProcessMessage(d amqp091.Delivery) {
fmt.Printf("Processing the message: %s\n", d.Body)
command := strings.Split(string(d.Body), ",")
if len(command) < 1 {
fmt.Println("Invalid command format")
Expand Down

0 comments on commit 7d962c9

Please sign in to comment.