Skip to content

Commit c4d5819

Browse files
author
Guy Baron
committed
fixing linting errors
1 parent 6e1e5b7 commit c4d5819

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

gbus/bus.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -354,8 +354,8 @@ func (b *DefaultBus) NotifyHealth(health chan error) {
354354

355355
//GetHealth implements Health.GetHealth
356356
func (b *DefaultBus) GetHealth() HealthCard {
357-
var dbConnected bool
358-
dbConnected = b.TxProvider.Ping(b.DbPingTimeout)
357+
358+
dbConnected := b.TxProvider.Ping(b.DbPingTimeout)
359359

360360
return HealthCard{
361361
DbConnected: dbConnected,

gbus/outbox.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ func (out *AMQPOutbox) init(amqp *amqp.Channel, confirm, resendOnNack bool) erro
5050
return nil
5151
}
5252

53-
func (out *AMQPOutbox) shutdown() {
53+
func (out *AMQPOutbox) Shutdown() {
5454
out.stop <- true
5555

5656
}

gbus/tx/mysql/txoutbox.go

+1
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ func (outbox *TxOutbox) Start(amqpOut *gbus.AMQPOutbox) error {
8888

8989
//Stop forcess the transactional outbox to stop processing additional messages
9090
func (outbox *TxOutbox) Stop() error {
91+
outbox.amqpOutbox.Shutdown()
9192
close(outbox.exit)
9293
return nil
9394
}

0 commit comments

Comments
 (0)