diff --git a/broker/broker.go b/broker/broker.go
index 6e11b1c..ed67603 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -6,7 +6,11 @@ import (
 	"golang.org/x/time/rate"
 )
 
-var limiter = rate.NewLimiter(rate.Limit(0.3), 1)
+// once per minute
+var authlimiter = rate.NewLimiter(rate.Limit(1.0/60.0), 1)
+
+// thrice per minute
+var limiter = rate.NewLimiter(rate.Limit(1.0/20.0), 1)
 
 type Broker interface {
 	Search([]config.State) ([]Job, error)
diff --git a/broker/ntgvision.go b/broker/ntgvision.go
index c2a42c7..a83f1e5 100644
--- a/broker/ntgvision.go
+++ b/broker/ntgvision.go
@@ -2,6 +2,7 @@ package broker
 
 import (
 	"bytes"
+	"context"
 	"encoding/json"
 	"errors"
 	"fmt"
@@ -100,7 +101,6 @@ func (ntg NTGVision) search(states []config.State) (io.ReadCloser, error) {
 }
 
 func (ntg NTGVision) refreshAuth() error {
-	time.Sleep(time.Minute * 2) // TODO
 	b, _ := json.Marshal(map[string]string{
 		"username": config.Get().Brokers.NTG.Username,
 		"password": config.Get().Brokers.NTG.Password,
@@ -110,6 +110,7 @@ func (ntg NTGVision) refreshAuth() error {
 		return err
 	}
 	setNTGHeaders(request)
+	authlimiter.Wait(context.Background())
 	resp, err := http.DefaultClient.Do(request)
 	if err != nil {
 		return err
@@ -140,6 +141,7 @@ func (ntg NTGVision) _search(states []config.State) (io.ReadCloser, error) {
 		return nil, err
 	}
 	c := http.Client{Timeout: time.Minute}
+	limiter.Wait(context.Backgroud())
 	resp, err := c.Do(request)
 	if err != nil {
 		return nil, err