skip amqp tests when no AMQP_URI is set
@@ -14,6 +14,10 @@ import (
)
func setupConn(t *testing.T) (*amqp.Connection, *amqp.Channel) {
+ if os.Getenv("AMQP_URI") == "" {
+ t.Skip("skipping amqp test since there is no AMQP_URI")
+ }
+
amqpConn, err := amqp.Dial(os.Getenv("AMQP_URI"))
if err != nil {
t.Fatal(err)
