Changed message delivery delay

This commit is contained in:
Jackie Elliott 2018-08-02 17:40:47 -07:00
Родитель 4d7bc5de1a
Коммит 8c716e4a8d
1 изменённых файлов: 2 добавлений и 1 удалений

Просмотреть файл

@ -23,7 +23,8 @@ func SendToQueue(message string, exprireTime time.Time) error {
log.Printf("failed to build a new queue named %q\n", queueName)
return err
}
exprireTime = exprireTime.Add(time.Minute * time.Duration(5))
exprireTime = exprireTime.Add(time.Minute * time.Duration(10))
log.Print(exprireTime)
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
msg := servicebus.NewMessageFromString(message)
msg.SystemProperties = &servicebus.SystemProperties{