Skip to content
Snippets Groups Projects

Resolve "Add an option to send gNMI Subscribe requests via SBI"

2 files
+ 8
2
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -10,6 +10,7 @@ import (
interfaces "code.fbi.h-da.de/danet/gosdn/controller/interfaces/event"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/sirupsen/logrus"
)
// EventService is used to setup a connection to a broker and publish events to topics.
@@ -78,5 +79,7 @@ func (e *EventService) PublishEvent(topic string, event event.Event) error {
// CloseConnection closes an exisiting connection.
func (e *EventService) CloseConnection() {
e.connection.Close()
if err := e.connection.Close(); err != nil {
logrus.Error(err)
}
}
Loading