added shovel plugin to integration test

main_test.go

@@ -1,7 +1,10 @@
 package main
 
-import log "github.com/sirupsen/logrus"
+import (
+	log "github.com/sirupsen/logrus"
+	"io/ioutil"
+)
 
 func init() {
-	log.SetLevel(log.FatalLevel)
+	log.SetOutput(ioutil.Discard)
 }

testenv/Dockerfile

@@ -0,0 +1,2 @@
+FROM rabbitmq:3.7-management-alpine
+RUN rabbitmq-plugins enable --offline rabbitmq_shovel rabbitmq_shovel_management

testenv/testenv.go

@@ -48,11 +48,11 @@ func NewEnvironment(t *testing.T, dockerTag string) TestEnvironment {
 	tenv.docker.MaxWait = MaxWait
 
 	// pulls an image, creates a container based on it and runs it
-	resource, err := tenv.docker.RunWithOptions(&dockertest.RunOptions{Repository: "rabbitmq", Tag: dockerTag, Hostname: "localtest"})
-
+	resource, err := pool.BuildAndRunWithOptions("./testenv/Dockerfile", &dockertest.RunOptions{Name: "rabbitmq-test", Hostname: "localtest"})
 	if err != nil {
 		log.Fatalf("Could not start resource: %s", err)
 	}
+	resource.Expire(120)
 	tenv.resource = resource
 
 	checkManagementWebsite := func() error {