Commit 1c2449f7 authored by Trevor Conn's avatar Trevor Conn Committed by Trevor Conn

Update reference to go-mod-messaging, fix race condition

Fix #1509

- Also noticed that if an error were to occur during publishing, our
  logging was dropping that from the message. Added error contents to
  log output in this case.
Signed-off-by: default avatarTrevor Conn <>
parent 8525f6ab
......@@ -6,7 +6,7 @@ require ( v1.2.5 v1.1.1 v0.1.0 v0.1.0 v0.1.5 v0.1.0 v0.0.0-20181015135952-eeefdecb41b8 v0.8.0
......@@ -252,7 +252,7 @@ func putEventOnQueue(evt models.Event, ctx context.Context) {
msgEnvelope := msgTypes.NewMessageEnvelope(evt.Bytes, ctx)
err := msgClient.Publish(msgEnvelope, Configuration.MessageQueue.Topic)
if err != nil {
LoggingClient.Error(fmt.Sprintf("Unable to send message for event: %s", evt.String()))
LoggingClient.Error(fmt.Sprintf("Unable to send message for event: %s %v", evt.String(), err))
} else {
LoggingClient.Info(fmt.Sprintf("Event Published on message queue. Topic: %s, Correlation-id: %s ", Configuration.MessageQueue.Topic, msgEnvelope.CorrelationID))
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment