Skip to content
Snippets Groups Projects

WIP: Develop

Merged Malte Bauch requested to merge develop into master
3 files
+ 131
122
Compare changes
  • Side-by-side
  • Inline
Files
3
package eventservice
package eventservice
import (
import (
 
"context"
"encoding/json"
"encoding/json"
"code.fbi.h-da.de/danet/gosdn/controller/config"
"code.fbi.h-da.de/danet/gosdn/controller/config"
@@ -61,7 +62,8 @@ func (e *EventService) PublishEvent(topic string, event event.Event) error {
@@ -61,7 +62,8 @@ func (e *EventService) PublishEvent(topic string, event event.Event) error {
return &errors.ErrCouldNotMarshall{Identifier: topic + " " + event.EntityID.String(), Type: event.Type, Err: err}
return &errors.ErrCouldNotMarshall{Identifier: topic + " " + event.EntityID.String(), Type: event.Type, Err: err}
}
}
err = e.channel.Publish(
err = e.channel.PublishWithContext(
 
context.TODO(),
"", // exchange
"", // exchange
q.Name, // routing key
q.Name, // routing key
false, // mandatory
false, // mandatory
Loading