use custom queue/exchange name

openzipkin · Dec 10, 2020 · 085fbb9 · 085fbb9
1 parent 705fed4
commit 085fbb9
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/reporter/amqp/amqp.go b/reporter/amqp/amqp.go
@@ -138,24 +138,24 @@ func (r *rmqReporter) Send(s model.SpanModel) {
 		Body: m,
 	}
 
-	err = r.channel.Publish(defaultRmqExchange, defaultRmqRoutingKey, false, false, msg)
+	err = r.channel.Publish(r.exchange, r.queue, false, false, msg)
 	if err != nil {
 		r.e <- fmt.Errorf("failed when publishing the span: %s\n", err.Error())
 	}
 }
 
 func (r *rmqReporter) queueBindVerify() error {
 	return r.channel.QueueBind(
-		defaultRmqRoutingKey,
-		defaultRmqRoutingKey,
-		defaultRmqExchange,
+		r.queue,
+		r.queue,
+		r.exchange,
 		false,
 		nil)
 }
 
 func (r *rmqReporter) exchangeVerify() error {
 	err := r.channel.ExchangeDeclare(
-		defaultRmqExchange,
+		r.exchange,
 		defaultExchangeKind,
 		true,
 		false,
@@ -173,7 +173,7 @@ func (r *rmqReporter) exchangeVerify() error {
 
 func (r *rmqReporter) queueVerify() error {
 	_, err := r.channel.QueueDeclare(
-		defaultRmqExchange,
+		r.queue,
 		true,
 		false,
 		false,