consumer.go

package main

import (
	"fmt"
	"github.com/streadway/amqp"
)


func main() {
	fmt.Println(".")

	conn, err := amqp.Dial("amqps://jEET11HDo04kR0bEFe:[email protected]/%2Funifiedfeed%2F31285")
	if err != nil {
		fmt.Println(err)
		panic(err)
	}

	chnl, err := conn.Channel()
	if err != nil {
		fmt.Println(err)
		panic(err)
	}

	qee, err := chnl.QueueDeclare(
		"",    // name, leave empty to generate a unique name
		false, // durable
		true,  // delete when unused
		true,  // exclusive
		false, // noWait
		nil,   // arguments
	)
	if err != nil {
		fmt.Println(err)
		panic(err)
	}

	err = chnl.QueueBind(
		qee.Name,      // name of the queue
		"#", // bindingKey
		"unifiedfeed", // sourceExchange
		false,         // noWait
		nil,           // arguments
	)

	consumerTag := ""
	msgs, err := chnl.Consume(
		qee.Name,    // queue
		consumerTag, // consumerTag
		true,        // auto-ack
		true,        // exclusive
		false,       // no-local
		false,       // no-wait
		nil,         // args
	)

	if err != nil {
		fmt.Println(err)
		panic(err)
	}

	forver := make(chan bool)
	go func(){
		for d := range msgs{
			fmt.Println(string(d.Body))
		}
	}()





	defer chnl.Close()
	defer conn.Close()

	<-forver
}