mirror of
https://git.rwth-aachen.de/acs/public/villas/web-backend-go/
synced 2025-03-30 00:00:12 +01:00
Merge branch 'amqp-no-periodic-ping' into 'master'
amqp: do not send periodical pings anymore See merge request acs/public/villas/web-backend-go!29
This commit is contained in:
commit
d2c037a4e0
1 changed files with 3 additions and 21 deletions
|
@ -24,13 +24,14 @@ package infrastructure_component
|
|||
import (
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"log"
|
||||
"time"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"github.com/google/uuid"
|
||||
"github.com/jinzhu/gorm"
|
||||
"github.com/jinzhu/gorm/dialects/postgres"
|
||||
"github.com/streadway/amqp"
|
||||
"log"
|
||||
"time"
|
||||
)
|
||||
|
||||
const VILLAS_EXCHANGE = "villas"
|
||||
|
@ -239,25 +240,6 @@ func StartAMQP(AMQPurl string, api *gin.RouterGroup) error {
|
|||
// register IC action endpoint only if AMQP client is used
|
||||
RegisterAMQPEndpoint(api.Group("/ic"))
|
||||
|
||||
// Periodically call the Ping function to check which ICs are still there
|
||||
ticker := time.NewTicker(10 * time.Second)
|
||||
go func() {
|
||||
|
||||
for {
|
||||
select {
|
||||
case <-ticker.C:
|
||||
//TODO Add a useful regular event here
|
||||
/*
|
||||
err = PingAMQP()
|
||||
if err != nil {
|
||||
log.Println("AMQP Error: ", err.Error())
|
||||
}
|
||||
*/
|
||||
}
|
||||
}
|
||||
|
||||
}()
|
||||
|
||||
log.Printf("Connected AMQP client to %s", AMQPurl)
|
||||
}
|
||||
|
||||
|
|
Loading…
Add table
Reference in a new issue