Merge pull request #46 from hellofresh/feature/named-connection

PT-5350 Added connection name parameter

.travis.yml

@@ -4,7 +4,7 @@ services:
  - docker
 
 go:
- - "1.11"
+ - "1.12"
  - "stable"
 
 env:
@@ -18,7 +18,7 @@ install:
  - make deps
 
 script:
- - make $MAKE_TASK
+ - env GO111MODULE=on make $MAKE_TASK
 
 after_script:
  - docker-compose down -v

Makefile

@@ -4,11 +4,9 @@ OK_COLOR=\033[32;01m
 PKG_SRC := github.com/hellofresh/goengine
 
 deps:
- @echo "$(OK_COLOR)==> Installing dependencies$(NO_COLOR)"
- @go get -u github.com/golang/dep/cmd/dep
+ @echo "$(OK_COLOR)==> Installing test dependencies$(NO_COLOR)"
  @go get -u github.com/onsi/ginkgo/ginkgo
  @go get -u github.com/onsi/gomega
- @dep ensure -v -vendor-only
 
 vet:
  @echo "$(OK_COLOR)==> checking code correctness with 'go vet' tool$(NO_COLOR)"

cmd/goengine/main.go

@@ -59,7 +59,7 @@ func main() {
  registry.RegisterType(&RecipeRated{})
 
  goengine.Log("Setting up the event bus", map[string]interface{}{"dsn": brokerDSN}, nil)
- bus := rabbit.NewEventBus(brokerDSN, "events", "events")
+ bus := rabbit.NewEventBus(brokerDSN, "events", "events", "goengine-test")
 
  goengine.Log("Setting up the event store", nil, nil)
  eventStore := mongodb.NewEventStore(mongoClient.Database("event_store"), registry)

go.mod

@@ -0,0 +1,21 @@
+module github.com/hellofresh/goengine
+
+go 1.12
+
+require (
+ github.com/go-stack/stack v1.8.0 // indirect
+ github.com/gofrs/uuid v3.2.0+incompatible
+ github.com/golang/snappy v0.0.0-20180518054509-2e65f85255db // indirect
+ github.com/onsi/ginkgo v1.7.0
+ github.com/onsi/gomega v1.4.3
+ github.com/streadway/amqp v0.0.0-20181205114330-a314942b2fd9
+ github.com/xdg/scram v0.0.0-20180814205039-7eeb5667e42c // indirect
+ github.com/xdg/stringprep v0.0.0-20180714160509-73f8eece6fdc // indirect
+ go.mongodb.org/mongo-driver v1.0.0
+ golang.org/x/crypto v0.0.0-20190130090550-b01c7a725664 // indirect
+ golang.org/x/net v0.0.0-20190125091013-d26f9f9a57f3 // indirect
+ golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4 // indirect
+ golang.org/x/sys v0.0.0-20190130150945-aca44879d564 // indirect
+ gopkg.in/fsnotify/fsnotify.v1 v1.4.7 // indirect
+ gopkg.in/yaml.v2 v2.2.2 // indirect
+)