Merge branch 'master' into v1.x

Author: Guy Baron

gbus/abstractions.go

@@ -138,6 +138,7 @@ type Deadlettering interface {
 	ReturnDeadToQueue(ctx context.Context, publishing *amqp.Publishing) error
 }
 
+
 //RawMessageHandling provides the ability to consume and send raq amqp messages with the transactional guarantees that the bus provides
 type RawMessageHandling interface {
 	/*

gbus/bus.go

@@ -554,6 +554,7 @@ func (b *DefaultBus) HandleDeadletter(handler RawMessageHandler) {
 	b.registerDeadLetterHandler(handler)
 }
 
+
 //SetGlobalRawMessageHandler implements RawMessageHandling.SetGlobalRawMessageHandler
 func (b *DefaultBus) SetGlobalRawMessageHandler(handler RawMessageHandler) {
 	metrics.AddHandlerMetrics(handler.Name())

gbus/saga/instance.go

@@ -49,6 +49,7 @@ func (si *Instance) invoke(exchange, routingKey string, invocation *sagaInvocati
 		}).Info("invoking method on saga")
 
 		span, sctx := opentracing.StartSpanFromContext(invocation.Ctx(), methodName)
+    
 		// replace the original context with the conext built around the span so we ca
 		// trace the saga handler that is invoked
 		invocation.ctx = sctx

tests/testMessages.go

@@ -9,6 +9,7 @@ var _ gbus.Message = &Reply2{}
 var _ gbus.Message = &Event1{}
 var _ gbus.Message = &Event2{}
 
+
 //PoisonMessage is a malformed message to test poison pill scenarios
 type PoisonMessage struct {
 }