timpamungkas

svcavallar / rabbitmq_reconnect.go

Created September 20, 2016 22:23

Golang example to reconnect to RabbitMQ on a connection closed event

	package main

	import (
	"flag"
	"github.com/streadway/amqp"
	"log"
	"time"
	)

	var amqpUri = flag.String("r", "amqp://guest:[email protected]/", "RabbitMQ URI")