fix

consul/discovery.go

@@ -78,7 +78,7 @@ func (s *Service) UpdateTTL(service *consul.AgentServiceRegistration) {
 				log.Println(err)
 			}
 		} else {
-			if err := s.ConsulAgent.PassTTL("service:"+s.AppID, "OK"); err != nil {
+			if err := s.ConsulAgent.PassTTL("service:"+s.Name+"_"+s.AppID, "OK"); err != nil {
 				log.Println(err)
 			}
 		}
@@ -121,6 +121,7 @@ func (s *Service) getTags() []string {
 		// "traefik.http.services." + s.Name + ".loadbalancer.server.scheme=http",
 		// "traefik.http.services." + s.Name + ".loadbalancer.server.port=" + port,
 		"traefik.http.services." + s.Name + ".loadbalancer.passhostheader=false",
+		"traefik.http.services." + s.Name + ".loadbalancer.servers." + fullName + "=" + bFullAddr,
 		"traefik.http.services." + s.Name + ".loadbalancer.servers." + fullName + ".url=" + bFullAddr,
 		"traefik.http.middlewares.compress.compress=true",
 		"traefik.http.middlewares.requestid.plugin.requestid.headerName=X-Request-ID",

rabbitmq/connect.go

@@ -0,0 +1,26 @@
+package rabbitmq
+
+import (
+	"log"
+
+	"github.com/streadway/amqp"
+)
+
+func Open(url string) (*amqp.Connection, *amqp.Channel, error) {
+	conn, err := amqp.Dial(url)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	ch, err := conn.Channel()
+	if err != nil {
+		log.Printf("Failed to open a channel: %v\n", err)
+		return nil, nil, err
+	}
+
+	return conn, ch, nil
+}
+
+func Close(conn *amqp.Connection) {
+	conn.Close()
+}