@ulrich > can you try adding
message.Dispose()
after the call to Publish, like this:
publishErr := directPublisher.Publish(message, resource.TopicOf(topic))
if publishErr != nil {
panic(publishErr)
}
log.Info(“message published:”, messageBody)
message.Dispose()