Merge pull request #42 from HeavyHorst/2123

removed unnecessary pointers

Author: matryer

queues/nats/nats.go

@@ -26,8 +26,8 @@ type publisher interface {
 
 // Transport is a vice.Transport for NATS queue.
 type Transport struct {
-	*sync.Mutex
-	wg *sync.WaitGroup
+	sync.Mutex
+	wg sync.WaitGroup
 
 	receiveChans map[string]chan []byte
 	sendChans    map[string]chan []byte
@@ -56,9 +56,6 @@ func New(opts ...Option) *Transport {
 	}
 
 	return &Transport{
-		Mutex: &sync.Mutex{},
-		wg:    &sync.WaitGroup{},
-
 		NatsAddr: DefaultAddr,
 
 		receiveChans: make(map[string]chan []byte),

queues/redis/redis.go

@@ -14,8 +14,8 @@ type Transport struct {
 	sendChans    map[string]chan []byte
 	receiveChans map[string]chan []byte
 
-	*sync.Mutex
-	wg *sync.WaitGroup
+	sync.Mutex
+	wg sync.WaitGroup
 
 	errChan     chan error
 	stopchan    chan struct{}
@@ -35,8 +35,6 @@ func New(opts ...Option) *Transport {
 	return &Transport{
 		sendChans:    make(map[string]chan []byte),
 		receiveChans: make(map[string]chan []byte),
-		Mutex:        &sync.Mutex{},
-		wg:           &sync.WaitGroup{},
 		errChan:      make(chan error, 10),
 		stopchan:     make(chan struct{}),
 		stopPubChan:  make(chan struct{}),

queues/sqs/sqs.go

@@ -14,8 +14,8 @@ import (
 
 // Transport is a vice.Transport for Amazon's SQS
 type Transport struct {
-	wg *sync.WaitGroup
-  
+	wg sync.WaitGroup
+
 	sm        sync.Mutex
 	sendChans map[string]chan []byte
 
@@ -33,7 +33,6 @@ type Transport struct {
 // New returns a new transport
 func New() *Transport {
 	return &Transport{
-		wg:           &sync.WaitGroup{},
 		sendChans:    make(map[string]chan []byte),
 		receiveChans: make(map[string]chan []byte),
 		errChan:      make(chan error, 10),