Skip to content

Commit 601aa0f

Browse files
author
Guy Baron
committed
gofmt fixes
1 parent b54e818 commit 601aa0f

3 files changed

Lines changed: 1 addition & 3 deletions

File tree

gbus/abstractions.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,6 @@ type Deadlettering interface {
138138
ReturnDeadToQueue(ctx context.Context, publishing *amqp.Publishing) error
139139
}
140140

141-
142141
//RawMessageHandling provides the ability to consume and send raq amqp messages with the transactional guarantees that the bus provides
143142
type RawMessageHandling interface {
144143
/*

gbus/bus.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -554,7 +554,6 @@ func (b *DefaultBus) HandleDeadletter(handler RawMessageHandler) {
554554
b.registerDeadLetterHandler(handler)
555555
}
556556

557-
558557
//SetGlobalRawMessageHandler implements RawMessageHandling.SetGlobalRawMessageHandler
559558
func (b *DefaultBus) SetGlobalRawMessageHandler(handler RawMessageHandler) {
560559
metrics.AddHandlerMetrics(handler.Name())

gbus/saga/instance.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ func (si *Instance) invoke(exchange, routingKey string, invocation *sagaInvocati
4949
}).Info("invoking method on saga")
5050

5151
span, sctx := opentracing.StartSpanFromContext(invocation.Ctx(), methodName)
52-
52+
5353
// replace the original context with the conext built around the span so we ca
5454
// trace the saga handler that is invoked
5555
invocation.ctx = sctx

0 commit comments

Comments
 (0)