consumer definition

definition.go

func() {	
  // create consumer
  c := consumer.NewConsumer(q, facade)

  ch, _ := amqpSession.GetConnection().Channel()
  interruptor := grupttor.NewGrupttor(
    handlers.NewAmqpHandler(
      ch,
      q.GetTag(),
    ),
    []grupttor.Hook{hooks.NewSystemInterruptHook([]os.Signal{syscall.SIGTERM})},
  )

  go interruptor.StartAndWait()

  // start consuming messages
  q.Consume(c.Consume(interruptor), 1)
}