This commit is contained in:
Adam Majer 2024-08-27 11:16:07 +02:00
parent 035f77cd15
commit 17d3d9c8c4

View File

@ -100,10 +100,6 @@ func ConnectToExchangeForPublish(host, username, password string) {
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel() defer cancel()
if DebugMode {
log.Println(msg)
}
err = ch.PublishWithContext(ctx, "pubsub", msg.Topic, false, false, rabbitmq.Publishing{ err = ch.PublishWithContext(ctx, "pubsub", msg.Topic, false, false, rabbitmq.Publishing{
ContentType: "application/json", ContentType: "application/json",
AppId: AppName, AppId: AppName,